公司网站开发的工作内容,湖北网站建设免费,南通建设招聘信息网站,一手货源怎么找1、DataGen SQL 连接器
FLinkSQL中可以使用内置的DataGen SQL 连接器来生成测试数据
官网链接#xff1a;DataGen SQL 连接器 2、随机数数据生成器
随机数数据生成器支持随机生成 char、varchar、binary、varbinary、string 类型的数据
它是一个无界流的数据生成器
-- TO…1、DataGen SQL 连接器
FLinkSQL中可以使用内置的DataGen SQL 连接器来生成测试数据
官网链接DataGen SQL 连接器 2、随机数数据生成器
随机数数据生成器支持随机生成 char、varchar、binary、varbinary、string 类型的数据
它是一个无界流的数据生成器
-- TODO 随机数数据生成器 创建source表
drop table random_datagen_source_table;
CREATE TABLE random_datagen_source_table (user_name string,user_id int) WITH (connector datagen,rows-per-second1, -- 指定生成速率每秒生成的行数(默认值:10000)-- TODO 对表中的每个字段进行配置-- 生成随机整数fields.user_id.kindrandom, -- 指定 数据生成器类型random 随机数fields.user_id.min1, -- 指定 随机数的最小值 fields.user_id.max1000, -- 指定 随机数的最大值 -- 生成随机字符串(字段类型为string时可以指定string长度)fields.user_name.kindrandom, -- 指定 数据生成器类型random 随机数fields.user_name.length3 -- 指定 随机生成字符串的长度
);-- 流式SQL
select * from random_datagen_source_table;
运行结果 3、序列生成器
序列数据生成器可以根据指定的起始值和结束值生成连续的整数数据
当序列数字达到结束值读取结束所以它是有界的生成器
-- TODO 序列数据生成器 创建source表
drop table sequence_datagen_source_table;
CREATE TABLE sequence_datagen_source_table (user_id int
) WITH (connector datagen,rows-per-second1, -- 指定生成速率每秒生成的行数(默认值:10000)-- TODO 对表中的每个字段进行配置fields.user_id.kindsequence, -- 指定 数据生成器类型sequence 序列fields.user_id.start1, -- 指定 序列的起始值fields.user_id.end120 -- 指定 序列的结束值
);-- 批式SQL
select * from sequence_datagen_source_table;
运行结果
