本文主要是介绍【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连接器(测试利器)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!