【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'