数据湖探索 DLI-DLI SDK与API的对应关系:Flink作业相关

时间:2024-01-17 18:08:49

Flink作业相关

表5 Flink作业相关API&SDK的对应关系表

Class

Method

Java Method

Python Method

API

Job

创建Flink SQL作业

submitFlinkSqlJob

-

POST /v1.0/{project_id}/streaming/sql-jobs

创建Flink自定义作业

createFlinkJarJob

-

POST /v1.0/{project_id}/streaming/flink-jobs

更新Flink SQL作业

updateFlinkSqlJob

-

PUT /v1.0/{project_id}/streaming/sql-jobs/{job_id}

更新Flink自定义作业

updateFlinkJarJob

-

PUT /v1.0/{project_id}/streaming/flink-jobs/{job_id}

查询Flink作业列表

getFlinkJobs

-

GET /v1.0/{project_id}/streaming/jobs

查询Flink作业详情

getFlinkJobDetail

-

GET /v1.0/{project_id}/streaming/jobs/{job_id}

查询Flink作业执行计划图

getFlinkJobExecuteGraph

-

GET /v1.0/{project_id}/streaming/jobs/{job_id}/execute-graph

查询Flink作业监控信息

getFlinkJobsMetrics

-

POST /v1.0/{project_id}/streaming/jobs/metrics

查询Flink作业APIG网关服务访问地址

getFlinkApigSinks

-

GET /v1.0/{project_id}/streaming/jobs/{job_id}/apig-sinks

运行Flink作业

runFlinkJob

-

POST /v1.0/{project_id}/streaming/jobs/run

停止Flink作业

stopFlinkJob

-

POST /v1.0/{project_id}/streaming/jobs/stop

批量删除Flink作业

deleteFlinkJobInBatch

-

POST /v1.0/{project_id}/streaming/jobs/delete

support.huaweicloud.com/sdkreference-dli/dli_04_0123.html