当前位置: 首页 > article >正文

【Flink】FlinkSQL的DataGen连接器(测试利器)

简介

我们在实际开发过程中可以使用FlinkSQL的DataGen连接器实现FlinkSQL的批或者流模拟数据生成,DataGen 连接器允许按数据生成规则进行读取,但注意:DataGen连接器不支持复杂类型: Array,Map,Row。 请用计算列构造这些类型
 

创建有界DataGen表

CREATE TABLE test (
  a INT,
  b STRING,
  createtime TIMESTAMP(3),
  WATERMARK FOR createtime AS createtime - INTERVAL '5' SECOND
) WITH (
 'connector' = 'datagen',
 'fields.a.kind'='sequence',
 'fields.a.start'='1',
 'fields.a.end'='10'
);
 

有界 DataGen连接器需要上述参数,只会生成固定范围的数据从设置的start到end

fields.a.kind中的a为列名,最后的参数必须为sequence,

必须有fields.a.start和'fields.a.end,其中a为自定义的列名

创建无界DataGen表

CREATE TABLE streamTable(
  a INT,
  c STRING,
  createtime TIMESTAMP(3)
) WITH (
 'connector'


http://www.kler.cn/a/232716.html

相关文章:

  • Jupyter notebook中运行dos指令运行方法
  • Pandas库的常用内容归纳
  • K8S集群常用命令
  • HTML中link的用法
  • h5使用video播放时关掉vant弹窗视频声音还在后台播放
  • 【机器学习:二十二、机器学习项目开发的技巧】
  • arkTS开发鸿蒙OS应用(登录页面实现,连接数据库)
  • 158基于matlab的用于分析弧齿锥齿轮啮合轨迹的程序
  • flink反压及解决思路和实操
  • (十八)springboot实战——spring securtity注解方式的授权流程源码解析
  • 如何连接ChatGPT?无需科学上网,使用官方GPT教程
  • AT_abl_d 题解
  • Java基础常见面试题总结-并发(二)
  • 淘宝镜像到期如何切换镜像及如何安装淘宝镜像
  • Git版本与分支
  • IPMI命令
  • 元宇宙虚拟数字人实训室:推动高校培养创新技术人才
  • 【每日一题】LeetCode——链表的中间结点
  • Python:批量url链接保存为PDF
  • 智能运维哪些算法?智能运维包含哪些
  • 多模态对比语言图像预训练CLIP:打破语言与视觉的界限,具备零样本能力
  • [Vue3]父子组件相互传值数据同步
  • Redis发布订阅及事务管理
  • docker常用10条容器操作命令
  • 阿里 EasyExcel 表头国际化
  • Vue3——模板语法(文本插值、vue内置指令)