Mapping Between DLI SDKs and APIs
OBS Authorization SDKs
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Authorize |
OBS authorization |
- |
POST /v1.0/{project_id}/dli/obs-authorize |
Queue-related SDKs
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Queue |
Creating a Queue |
- |
POST /v1.0/{project_id}/queues |
|
Deleting a Queue |
- |
DELETE /v1.0/{project_id}/queues/{queue_name} |
||
Obtaining the Default Queue |
- |
- |
||
Querying All Queues |
GET/v1.0/{project_id}/queues |
Resource-related SDKs
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
packageResources |
Uploading a Resource Package |
POST /v2.0/{project_id}/resources |
||
Deleting a Resource Package |
DELETE /v2.0/{project_id}/resources/{resource_name} |
|||
Querying All Resource Packages |
GET /v2.0/{project_id}/resources |
|||
Querying a Specified Resource Package |
GET /v2.0/{project_id}/resources/{resource_name} |
SDKs Related to SQL Jobs
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Database |
Creating a Database |
POST /v1.0/{project_id}/databases |
||
Deleting a Database |
DELETE /v1.0/{project_id}/databases/{database_name} |
|||
Querying All Databases |
GET /v1.0/{project_id}/databases |
|||
Modifying a Database User |
- |
- |
PUT /v1.0/{project_id}/databases/{database_name}/owner |
|
Table |
Creating a DLI Table |
POST /v1.0/{project_id}/databases/{database_name}/tables |
||
Creating an OBS Table |
POST /v1.0/{project_id}/databases/{database_name}/tables |
|||
Deleting a Table |
DELETE /v1.0/{project_id}/databases/{database_name}/tables/{table_name} |
|||
Querying All Tables |
GET /v1.0/{project_id}/databases/{database_name}/tables?keyword=tb&with-detail=true |
|||
Describing Table Information |
GET /v1.0/{project_id}/databases/{database_name}/tables/{table_name} |
|||
Previewing a Table |
- |
- |
GET /v1.0/{project_id}/databases/{database_name}/tables/{table_name}/preview |
|
Modifying a Table User |
- |
- |
PUT /v1.0/{project_id}/databases/{database_name}/tables/{table_name}/owner |
|
Job |
Importing Data |
POST /v1.0/{project_id}/jobs/import-table |
||
Exporting Data |
POST /v1.0/{project_id}/jobs/export-table |
|||
Submitting a Job |
POST /v1.0/{project_id}/jobs/submit-job |
|||
Canceling a Job |
- |
DELETE /v1.0/{project_id}/jobs/{job_id} |
||
Querying All Jobs |
- |
GET /v1.0/{project_id}/jobs?page-size={size}¤t-page={page_number}&start={start_time}&end={end_time}&job-type={QUERY}&queue_name={test}&order={duration_desc} |
||
Querying Job Results |
- |
GET/v1.0/{project_id}/jobs/{job_id}?page-size={size}¤t-page={page_number} |
||
Querying Job Status |
- |
- |
GET/v1.0/{project_id}/jobs/{job_id}/status |
|
Querying Job Details |
- |
- |
GET/v1.0/{project_id}/jobs/{job_id}/detail |
|
Querying Jobs of the SQL Type |
- |
- |
||
Checking the SQL Syntax |
- |
- |
POST /v1.0/{project_id}/jobs/check-sql |
|
Exporting Search Results |
- |
- |
POST /v1.0/{project_id}/jobs/{job_id}/export-result |
SDKs Related to Flink Jobs
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
Job |
Creating a Flink SQL Job |
- |
POST /v1.0/{project_id}/streaming/sql-jobs |
|
Creating a Custom Flink Job |
- |
POST /v1.0/{project_id}/streaming/flink-jobs |
||
Updating a Flink SQL Job |
- |
PUT /v1.0/{project_id}/streaming/sql-jobs/{job_id} |
||
Updating a Custom Flink Job |
- |
PUT /v1.0/{project_id}/streaming/flink-jobs/{job_id} |
||
Querying the List of Jobs |
- |
GET /v1.0/{project_id}/streaming/jobs |
||
Querying Flink Job Details |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id} |
||
Querying the Flink Job Execution Plan Diagram |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id}/execute-graph |
||
Querying Flink Job Monitoring Information |
- |
POST /v1.0/{project_id}/streaming/jobs/metrics |
||
Querying the APIG Address of a Flink Job |
- |
GET /v1.0/{project_id}/streaming/jobs/{job_id}/apig-sinks |
||
Running a Flink Job |
- |
POST /v1.0/{project_id}/streaming/jobs/run |
||
Stopping a Flink Job |
- |
POST /v1.0/{project_id}/streaming/jobs/stop |
||
Deleting Flink Jobs in Batches |
- |
POST /v1.0/{project_id}/streaming/jobs/delete |
SDKs Related to Spark Jobs
Class |
Method |
Java Method |
Python Method |
API |
---|---|---|---|---|
BatchJob |
Submitting Batch Jobs |
POST /v2.0/{project_id}/batches |
||
Deleting Batch Jobs |
DELETE /v2.0/{project_id}/batches/{batch_id} |
|||
Querying All Batch Jobs |
- |
GET /v2.0/{project_id}/batches |
||
Querying Batch Job Details |
- |
- |
GET /v2.0/{project_id}/batches/{batch_id} |
|
Querying a Batch Job Status |
- |
GET /v2.0/{project_id}/batches/{batch_id}/state |
||
Querying Batch Job Logs |
- |
GET /v2.0/{project_id}/batches/{batch_id}/log |
SDKs Related to Flink Job Templates
Class |
Java Method |
Python Method |
API |
---|---|---|---|
Template |
- |
POST /v1.0/{project_id}/streaming/job-templates |
|
- |
PUT /v1.0/{project_id}/streaming/job-templates/{template_id} |
||
- |
DELETE /v1.0/{project_id}/streaming/job-templates/{template_id} |
||
- |
GET /v1.0/{project_id}/streaming/job-templates |
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot