简介
我们在实际开发过程中可以使用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’
原文地址:https://blog.csdn.net/sinat_23225111/article/details/136041892
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.7code.cn/show_67051.html
如若内容造成侵权/违法违规/事实不符，请联系代码007邮箱：suwngjj01@126.com进行投诉反馈，一经查实，立即删除！
