数据湖探索 DLI-生成Flink SQL作业的静态流图:请求示例

时间：2024-09-27 11:19:15

数据湖探索 DLI

请求示例

生成Flink SQL作业的静态流图，流图的类型为静态流图。

{
  "job_type": "flink_opensource_sql_job",
  "graph_type": "job_graph",
  "sql_body": "create table orders(\r\n  name string,\r\n  num int\r\n) with (\r\n  'connector' = 'datagen',\r\n  'rows-per-second' = '1', --每秒生成一条数据\r\n  'fields.name.kind' = 'random', --为字段user_id指定random生成器\r\n  'fields.name.length' = '5' --限制user_id长度为3\r\n);\r\n \r\nCREATE TABLE sink_table (\r\n  name string,\r\n  num int\r\n) WITH (\r\n   'connector' = 'print'\r\n);\r\nINSERT into sink_table SELECT * FROM orders;",
  "cu_number": 2,
  "manager_cu_number": 1,
  "parallel_number": 2,
  "tm_cus": 1,
  "tm_slot_num": 0,
  "operator_config": "",
  "static_estimator": true,
  "flink_version": "1.12",
  "static_estimator_config": "{\"operator_list\":[{\"id\":\"0a448493b4782967b150582570326227\",\"output_rate\":1000},{\"id\":\"bc764cd8ddf7a0cff126f51c16239658\",\"output_rate\":1000}]}"
}

上一篇：数据湖探索 DLI-生成Flink SQL作业的静态流图:请求消息

下一篇：数据湖探索 DLI-生成Flink SQL作业的静态流图:响应示例