注意啟動Flink集群

①

CREATE TABLE source_table ( id INT, score INT, address STRING, ts AS localtimestamp, WATERMARK FOR ts AS ts ) WITH ('connector' = 'datagen','rows-per-second'='5','fields.id.kind'='sequence','fields.id.start'='1','fields.id.end'='100','fields.score.min'='1','fields.score.max'='100','fields.address.length'='10')

②

select * from source_table;

步驟②運行后會卡住,等待時間大概是9秒后才會出來隨機結果.

按下鍵盤上的q可以回到原來的客戶端

#########################################################################################################

再舉一例[2]:

CREATE TABLE datagen_dijie3 (f_sequence INT,f_random INT,f_random_str STRING ) WITH ('connector' = 'datagen','rows-per-second'='5','fields.f_sequence.kind'='sequence','fields.f_sequence.start'='1','fields.f_sequence.end'='1000','fields.f_random.min'='1','fields.f_random.max'='1000','fields.f_random_str.length'='10' );

select * from datagen_dijie3;

?

Reference:

[1]【Flink1.11新特性】DataGen和print方便測試

[2]Flink Sql on Zeppelin（6）——Flink1.11預覽（上）

[3]DataGen SQL Connector(官方文檔)

總結

以上是生活随笔為你收集整理的Flink SQL Client的datagen的用法(转载+自己验证)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。