数据湖探索 DLI-DLI SDK与API的对应关系:Flink作业相关
Flink作业相关
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Job |
创建Flink SQL作业 |
- |
POST /v1.0/{project_id}/streaming/sql-jobs |
|
创建Flink自定义作业 |
- |
POST /v1.0/{project_id}/streaming/flink-jobs |
||
更新Flink SQL作业 |
- |
PUT /v1.0/{project_id}/streaming/sql-jobs/{job_id} |
||
更新Flink自定义作业 |
- |
PUT /v1.0/{project_id}/streaming/flink-jobs/{job_id} |
||
查询Flink作业列表 |
- |
GET /v1.0/{project_id}/streaming/jobs |
||
查询Flink作业详情 |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id} |
||
查询Flink作业执行计划图 |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id}/execute-graph |
||
查询Flink作业监控信息 |
- |
POST /v1.0/{project_id}/streaming/jobs/metrics |
||
查询Flink作业APIG网关服务访问地址 |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id}/apig-sinks |
||
运行Flink作业 |
- |
POST /v1.0/{project_id}/streaming/jobs/run |
||
停止Flink作业 |
- |
POST /v1.0/{project_id}/streaming/jobs/stop |
||
批量删除Flink作业 |
- |
POST /v1.0/{project_id}/streaming/jobs/delete |