本文主要是介绍【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'
这篇关于【Flink】FlinkSQL的DataGen连接器（测试利器）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
