Mapping Between DLI SDKs and APIs

Authorize

OBS authorization

authorizeBucket

-

POST /v1.0/{project_id}/dli/obs-authorize

Queue

Creating a Queue

createQueue

-

POST /v1.0/{project_id}/queues

Deleting a Queue

deleteQueue

-

DELETE /v1.0/{project_id}/queues/{queue_name}

Obtaining the Default Queue

getDefaultQueue

-

-

Querying All Queues

listAllQueues

list_queues

GET/v1.0/{project_id}/queues

packageResources

Uploading a Resource Package

uploadResources

upload_resource

POST /v2.0/{project_id}/resources

Deleting a Resource Package

deleteResource

delete_resource

DELETE /v2.0/{project_id}/resources/{resource_name}

Querying All Resource Packages

listAllResources

list_resources

GET /v2.0/{project_id}/resources

Querying a Specified Resource Package

getResource

get_package_resource

GET /v2.0/{project_id}/resources/{resource_name}

Database

Creating a Database

createDatabase

create_database

POST /v1.0/{project_id}/databases

Deleting a Database

deleteDatabase

delete_database

DELETE /v1.0/{project_id}/databases/{database_name}

Querying All Databases

listAllDatabases

list_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

createDLITable

create_dli_table

POST /v1.0/{project_id}/databases/{database_name}/tables

Creating an OBS Table

createObsTable

create_obs_table

POST /v1.0/{project_id}/databases/{database_name}/tables

Deleting a Table

deleteTable

delete_table

DELETE /v1.0/{project_id}/databases/{database_name}/tables/{table_name}

Querying All Tables

listAllTables

list_tables

GET /v1.0/{project_id}/databases/{database_name}/tables?keyword=tb&with-detail=true

Describing Table Information

getTableDetail

get_table_schema

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

submit

import_table

POST /v1.0/{project_id}/jobs/import-table

Exporting Data

submit

export_table

POST /v1.0/{project_id}/jobs/export-table

Submitting a Job

submit

execute_sql

POST /v1.0/{project_id}/jobs/submit-job

Canceling a Job

cancelJob

-

DELETE /v1.0/{project_id}/jobs/{job_id}

Querying All Jobs

listAllJobs

-

GET /v1.0/{project_id}/jobs?page-size={size}&current-page={page_number}&start={start_time}&end={end_time}&job-type={QUERY}&queue_name={test}&order={duration_desc}

Querying Job Results

queryJobResultInfo

-

GET/v1.0/{project_id}/jobs/{job_id}?page-size={size}&current-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

listSQLJobs

-

-

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

Job

Creating a Flink SQL Job

submitFlinkSqlJob

-

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

Creating a Custom Flink Job

createFlinkJarJob

-

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

Updating a Flink SQL Job

updateFlinkSqlJob

-

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

Updating a Custom Flink Job

updateFlinkJarJob

-

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

Querying the List of Jobs

getFlinkJobs

-

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

Querying Flink Job Details

getFlinkJobDetail

-

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

Querying the Flink Job Execution Plan Diagram

getFlinkJobExecuteGraph

-

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

Querying Flink Job Monitoring Information

getFlinkJobsMetrics

-

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

Querying the APIG Address of a Flink Job

getFlinkApigSinks

-

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

Running a Flink Job

runFlinkJob

-

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

Stopping a Flink Job

stopFlinkJob

-

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

Deleting Flink Jobs in Batches

deleteFlinkJobInBatch

-

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

BatchJob

Submitting Batch Jobs

asyncSubmit

submit_spark_batch_job

POST /v2.0/{project_id}/batches

Deleting Batch Jobs

deleteBatchJob

del_spark_batch_job

DELETE /v2.0/{project_id}/batches/{batch_id}

Querying All Batch Jobs

listAllBatchJobs

-

GET /v2.0/{project_id}/batches

Querying Batch Job Details

-

-

GET /v2.0/{project_id}/batches/{batch_id}

Querying a Batch Job Status

getStateBatchJob

-

GET /v2.0/{project_id}/batches/{batch_id}/state

Querying Batch Job Logs

getBatchJobLog

-

GET /v2.0/{project_id}/batches/{batch_id}/log

Template

createFlinkJobTemplate

-

POST /v1.0/{project_id}/streaming/job-templates

updateFlinkJobTemplate

-

PUT /v1.0/{project_id}/streaming/job-templates/{template_id}

deleteFlinkJobTemplate

-

DELETE /v1.0/{project_id}/streaming/job-templates/{template_id}

getFlinkJobTemplates

-

GET /v1.0/{project_id}/streaming/job-templates