开发一个手机系统有多难,济南正规企业站seo,拼图式网站开发,国外设计师个人网站简介
我们在实际开发过程中可以使用FlinkSQL的DataGen连接器实现FlinkSQL的批或者流模拟数据生成,DataGen 连接器允许按数据生成规则进行读取,但注意:DataGen连接器不支持复杂类型: Array,Map,Row。 请用计算列构造这些类型
创建有界DataGen表 CREATE TABLE test ( a…简介
我们在实际开发过程中可以使用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'