当前位置: 首页 > 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/news/232716.html

相关文章:

  • 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内置指令)
  • Vue 前置导航
  • OpenHarmony轻量级内核-LiteOS-M
  • final、finally、finalize区别
  • 8个简约精美的WordPress外贸网站主题模板
  • 编码技巧——基于RedisTemplate的RedisClient实现、操作Lua脚本
  • CentOS 安装 redis 7.2
  • 使用Launch4j将jar包转成.exe可执行文件
  • OCR文本纠错思路
  • C语言中的多级指针、指针数组与数组指针
  • 飞天使-k8s知识点15-kubernetes散装知识点4-CNI网络插件与kubectl