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

时间:2025-02-12 14:55:48

请求示例

生成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}]}"}
support.huaweicloud.com/api-dli/dli_02_0316.html