Package | Description |
---|---|
com.huawei.dli.restapi | |
com.huawei.dli.restapi.api |
Modifier and Type | Method and Description |
---|---|
<T> void |
ApiClient.executeAsync(okhttp3.Call call,
ApiCallback<T> callback)
|
<T> void |
ApiClient.executeAsync(okhttp3.Call call,
Type returnType,
ApiCallback<T> callback)
Execute HTTP call asynchronously.
|
Modifier and Type | Method and Description |
---|---|
okhttp3.Call |
RestApi.alertResourceOrGroupOwnerAsync(String projectId,
UpdateResourceOwner body,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Modify owner of resource (asynchronously)
Modify owner of resource.
|
okhttp3.Call |
RestApi.authorizeBucketAsync(String projectId,
ObsBuckets obsBuckets,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等 (asynchronously)
|
okhttp3.Call |
RestApi.cancelJob_0Async(String projectId,
String queueName,
String jobId,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Cancel job (asynchronously)
Canceling a job that has already been submitted can not be canceled if the job has been completed or failed.
|
okhttp3.Call |
RestApi.cancelJobAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Cancel job (asynchronously)
Canceling a job that has already been submitted can not be canceled if the job has been completed or failed.
|
okhttp3.Call |
RestApi.checkSQLAsync(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Check sql (asynchronously)
Check the SQL grammar.
|
okhttp3.Call |
RestApi.commitUploadJobAsync(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken,
ApiCallback<UploadCommitJobResult> callback)
Commit direct upload job (asynchronously)
Commit direct upload job for upload data to DLI.
|
okhttp3.Call |
RestApi.createBatchAsync(String projectId,
Object body,
String xAuthToken,
String USER_ID,
ApiCallback<SessionInfo> callback)
Create batch (asynchronously)
Create batch.
|
okhttp3.Call |
RestApi.createClusterAsync(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID,
ApiCallback<EmptyResponse> callback)
Create cluster (asynchronously)
Create cluster.
|
okhttp3.Call |
RestApi.createDatabaseAsync(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Create database (asynchronously)
create a database
|
okhttp3.Call |
RestApi.createDownloadJobAsync(String projectId,
EmptyBody emptyBody,
String xAuthToken,
ApiCallback<DownloadCreateJobResult> callback)
Create direct download job (asynchronously)
Create direct download job for download data from DLI.
|
okhttp3.Call |
RestApi.createFlinkJobTemplateAsync(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken,
ApiCallback<FlinkJobTemplateCreateResponse> callback)
创建作业模板 (asynchronously)
Create job template on Data lake insight
|
okhttp3.Call |
RestApi.createObsSelectJobAsync(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken,
ApiCallback<ObsSelectJobResult> callback)
Create Obs select job (asynchronously)
Create Obs select job to DLI.
|
okhttp3.Call |
RestApi.createQueueAsync(String projectId,
QueueInfo queueInfo,
String xAuthToken,
ApiCallback<ResponseQueueInfo> callback)
Create queue (asynchronously)
Create a queue that will bind user-specified computing resources.
|
okhttp3.Call |
RestApi.createTableAsync(String projectId,
String databaseName,
TableInfo tableInfo,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Create a new table (asynchronously)
Data location:DLI and OBS,OBS must set data_location and data_type parameter
|
okhttp3.Call |
RestApi.createTsdbAsync(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken,
ApiCallback<CreateTsdbResp> callback)
创建时序数据库配置信息 (asynchronously)
|
okhttp3.Call |
RestApi.createUploadJobAsync(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken,
ApiCallback<UploadCreateJobResult> callback)
Create direct upload job (asynchronously)
Create direct upload job for upload data to DLI.
|
okhttp3.Call |
RestApi.dataAuthorizeAsync(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
List queue users (asynchronously)
Privilege data permissions to the database or data table to other specified users.
|
okhttp3.Call |
RestApi.delBatchAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<MessageInfo> callback)
Delete specified batch (asynchronously)
Delete specified batch.
|
okhttp3.Call |
RestApi.deleteClusterAsync(String projectId,
String clusterName,
String xAuthToken,
ApiCallback<EmptyResponse> callback)
Delete cluster (asynchronously)
Delete cluster.
|
okhttp3.Call |
RestApi.deleteDatabaseAsync(String projectId,
String databaseName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete database (asynchronously)
Delete database by database name.
|
okhttp3.Call |
RestApi.deleteFlinkJobAsync(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
批量删除作业 (asynchronously)
|
okhttp3.Call |
RestApi.deleteFlinkJobTemplateAsync(String projectId,
Long templateId,
String xAuthToken,
ApiCallback<FlinkJobTemplateDeleteResponse> callback)
删除作业模板 (asynchronously)
当前模板被引用也允许删除模板
|
okhttp3.Call |
RestApi.deleteJobAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
删除作业 (asynchronously)
删除任何状态的作业
|
okhttp3.Call |
RestApi.deleteQueueAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete queue (asynchronously)
Delete the specified queue.
|
okhttp3.Call |
RestApi.deleteResourceAsync(String projectId,
String resourceName,
String group,
String xAuthToken,
ApiCallback<EmptyResponse> callback)
Delete specified resource (asynchronously)
Delete specified resource.
|
okhttp3.Call |
RestApi.deleteTableAsync(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete table (asynchronously)
Delete the specified table.
|
okhttp3.Call |
RestApi.deleteTsdbAsync(String projectId,
String tsdbId,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
删除时序数据库配置信息 (asynchronously)
删除时序数据库配置信息
|
okhttp3.Call |
RestApi.describeTableAsync(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ApiCallback<ColumnResult> callback)
Describe Table (asynchronously)
Describes the metadata information for the specified table.
|
okhttp3.Call |
RestApi.execute_0Async(String projectId,
String queueName,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Submit job (asynchronously)
This API is used to submit jobs to the cluster by executing SQL statements.
|
okhttp3.Call |
RestApi.executeAsync(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Submit job (asynchronously)
This API is used to submit jobs to the cluster by executing SQL statements.
|
okhttp3.Call |
RestApi.exportDataAsync(String projectId,
ExportJobRequest exportInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Export data (asynchronously)
Export the data to a file.
|
okhttp3.Call |
RestApi.getBatchInfoAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<SessionInfo> callback)
List specified batch (asynchronously)
List specified batch.
|
okhttp3.Call |
RestApi.getBatchListAsync(String projectId,
String xAuthToken,
String clusterName,
Integer from,
Integer size,
String jobId,
String jobName,
Long start,
Long end,
String order,
ApiCallback<SessionInfos> callback)
List all batchs (asynchronously)
List all batchs.
|
okhttp3.Call |
RestApi.getBatchLogAsync(String projectId,
String batchId,
String xAuthToken,
Integer from,
Integer size,
String type,
Integer index,
ApiCallback<SessionLog> callback)
Get specified batch log (asynchronously)
Get specified batch log.
|
okhttp3.Call |
RestApi.getBatchStateAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<SessionState> callback)
Get specified session state (asynchronously)
Get specified session state.
|
okhttp3.Call |
RestApi.getClusterAsync(String projectId,
String clusterName,
String xAuthToken,
ApiCallback<ClusterInfo> callback)
List specified cluster (asynchronously)
List specified cluster.
|
okhttp3.Call |
RestApi.getFlinkApigSinksAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<FlinkJobApigSinksResponse> callback)
查询作业apig网关服务访问地址 (asynchronously)
The apig sinks is json format.
|
okhttp3.Call |
RestApi.getFlinkJobDetailAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<GetFlinkJobDetailResponse> callback)
查询作业详情 (asynchronously)
Get job detail information.
|
okhttp3.Call |
RestApi.getFlinkJobExecuteGraphAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<FlinkJobExecutePlanResponse> callback)
查询作业执行计划图 (asynchronously)
The execution graph is json format.
|
okhttp3.Call |
RestApi.getFlinkJobsAsync(String projectId,
String xAuthToken,
String name,
String status,
String queueName,
Boolean showDetail,
Long offset,
Integer limit,
String order,
Long rootJobId,
String userName,
String jobType,
String showJobType,
ApiCallback<QueryFlinkJobListResponse> callback)
查询作业列表 (asynchronously)
作业列表查询, 支持以下参数: name, status, show_detail, cursor, next, limit, order, root_job_id.
|
okhttp3.Call |
RestApi.getFlinkJobsMetricsAsync(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken,
ApiCallback<QueryFlinkJobMetricsResponse> callback)
查询作业监控信息 (asynchronously)
查询作业监控信息, 支持同时查询多个作业监控信息
|
okhttp3.Call |
RestApi.getFlinkJobTemplatesAsync(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order,
ApiCallback<FlinkJobTemplateListResponse> callback)
查询作业模板列表 (asynchronously)
|
okhttp3.Call |
RestApi.getImportExportJobInfoAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<DetailResult> callback)
Import and Export detail (asynchronously)
Query the details of imported and exported jobs, such as the job's databaseName, tableName, file size, and export mode.
|
okhttp3.Call |
RestApi.getJobProgressAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<JobProgressResult> callback)
Get job progress (asynchronously)
Get job progress
|
okhttp3.Call |
RestApi.getJobResult_0Async(String projectId,
String queueName,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
ApiCallback<JobResult> callback)
Get job result (asynchronously)
After the job executing the SQL query is completed, review the result of the job execution.
|
okhttp3.Call |
RestApi.getJobResultAsync(String projectId,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String queueName,
ApiCallback<JobResult> callback)
Get job result (asynchronously)
After the job executing the SQL query is completed, review the result of the job execution.
|
okhttp3.Call |
RestApi.getJobStatusAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<StatusResult> callback)
Get job status (asynchronously)
Get job status after job submission.
|
okhttp3.Call |
RestApi.getResourceInfoAsync(String projectId,
String resourceName,
String group,
String xAuthToken,
ApiCallback<PkgResourceInfo> callback)
List specified resource (asynchronously)
List specified resource.
|
okhttp3.Call |
RestApi.getSpecifiedQueueAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<QueueInfo> callback)
Get queue (asynchronously)
Get the specified queue.
|
okhttp3.Call |
TokenAuthApi.getTokenAsync(TokenAuthInfo tokenAuthInfo,
ApiCallback<TokenAuthResponse> callback)
get token (asynchronously)
get token for authentication
|
okhttp3.Call |
RestApi.getTsdbByIdAsync(String projectId,
Long tsdbId,
String xAuthToken,
ApiCallback<GetTsdbByIdResp> callback)
查询时序数据库配置信息详情 (asynchronously)
根据时序数据库ID,查询时序数据库详情
|
okhttp3.Call |
RestApi.getTsdbListAsync(String projectId,
Integer offset,
Integer limit,
String xAuthToken,
ApiCallback<GetTsdbListResp> callback)
查询时序数据库配置信息列表 (asynchronously)
|
okhttp3.Call |
RestApi.importDataAsync(String projectId,
ImportJobRequest importExportInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Import data (asynchronously)
Importing data from a file into a DLI table currently only supports importing data from OBS into DLI.
|
okhttp3.Call |
RestApi.listAllDatabasesAsync(String projectId,
String xAuthToken,
ApiCallback<DatabaseResult> callback)
List all databases (asynchronously)
List all databases info,include owner and table_number.
|
okhttp3.Call |
RestApi.listAllJobsAsync(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
Long start,
Long end,
String jobType,
String tags,
String queueName,
String owner,
String jobStatus,
String order,
ApiCallback<JobListResult> callback)
List all jobs (asynchronously)
List all jobs
|
okhttp3.Call |
RestApi.listAllQueuesAsync(String projectId,
String xAuthToken,
String queueType,
ApiCallback<QueueResult> callback)
List all queues (asynchronously)
List all the queues under the project.
|
okhttp3.Call |
RestApi.listAllTablesAsync(String projectId,
String databaseName,
String xAuthToken,
String keyword,
Boolean withDetail,
Integer pageSize,
Integer currentPage,
String tableType,
ApiCallback<TableListResult> callback)
List all tables (asynchronously)
Query the specified database under the filter conditions or all of the table information.
|
okhttp3.Call |
RestApi.listClusterAsync(String projectId,
String xAuthToken,
ApiCallback<ClusterInfos> callback)
List all clusters (asynchronously)
List all clusters.
|
okhttp3.Call |
RestApi.listDatabaseUsersAsync(String projectId,
String databaseName,
String xAuthToken,
ApiCallback<PrivilegeResult> callback)
List Database Users (asynchronously)
View the current database has permission to use or access all user names.
|
okhttp3.Call |
RestApi.listQueueUsersAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<PrivilegeResult> callback)
List queue users (asynchronously)
Queries all the user names of the specified queue that can be used.
|
okhttp3.Call |
RestApi.listResourcesAsync(String projectId,
String xAuthToken,
String kind,
ApiCallback<ResourceInfos> callback)
List all resources (asynchronously)
List all resources.
|
okhttp3.Call |
RestApi.listSqlJobsAsync(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags,
ApiCallback<JobListResult> callback)
List all sql jobs (asynchronously)
List all sql jobs
|
okhttp3.Call |
RestApi.listTableUserPrivilegesAsync(String projectId,
String databaseName,
String tableName,
String userName,
String xAuthToken,
ApiCallback<PrivilegeResult> callback)
List Table User Privileges (asynchronously)
Query the specified user's privileges list on the table.
|
okhttp3.Call |
RestApi.listTableUsersAsync(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ApiCallback<PrivilegeResult> callback)
List Table Users (asynchronously)
View all users who have access to the columns of the specified table or table.
|
okhttp3.Call |
RestApi.previewJobResultAsync(String projectId,
String jobId,
String xAuthToken,
String queueName,
ApiCallback<JobResult> callback)
Get job result (asynchronously)
After the job executing the SQL query is completed, review the result of the job execution.
|
okhttp3.Call |
RestApi.queueActionAsync(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken,
ApiCallback<QueueActionResponse> callback)
队列操作 (asynchronously)
|
okhttp3.Call |
RestApi.runFlinkJobAsync(String projectId,
RunFlinkJobRequest body,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
运行作业 (asynchronously)
触发运行作业
|
okhttp3.Call |
RestApi.shareQueueAsync(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Share queues (asynchronously)
To share the specified queue with other users, you can assign the user the privilege to use the specified queue or to recover the usage privileges.
|
okhttp3.Call |
RestApi.showPartitionsAsync(String projectId,
String databaseName,
String tableName,
String xAuthToken,
Integer offset,
Integer limit,
ApiCallback<PartitionResult> callback)
Show partition information (asynchronously)
Describes the partition information for the specified table.
|
okhttp3.Call |
RestApi.stopFlinkJobAsync(String projectId,
StopFlinkJobRequest body,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
停止作业 (asynchronously)
|
okhttp3.Call |
RestApi.storeJobResultAsync(String projectId,
String jobId,
String xAuthToken,
ExportCommonInfo exportCommonInfo,
ApiCallback<ResponseJobInfo> callback)
Export job result (asynchronously)
Export the results of the SQL statement to the OBS object store and only support the export of query results for \"QUERY\" type jobs.
|
okhttp3.Call |
RestApi.submitFlinkJarJobAsync(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
创建一个用户自定义Flink作业 (asynchronously)
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.submitFlinkSqlJobAsync(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
提交流式SQL作业到DLI服务 (asynchronously)
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
okhttp3.Call |
RestApi.updateFlinkJarJobAsync(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新用户自定义Flink作业 (asynchronously)
目前仅支持Jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.updateFlinkJobTemplateAsync(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
更新作业模板 (asynchronously)
Update job template on Data lake insight
|
okhttp3.Call |
RestApi.updateFlinkSqlJobAsync(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新流式SQL作业 (asynchronously)
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
okhttp3.Call |
RestApi.updateTsdbAsync(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
修改时序数据库配置信息 (asynchronously)
修改时序数据库配置信息
|
okhttp3.Call |
RestApi.uploadFilesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload files (asynchronously)
Upload files.
|
okhttp3.Call |
RestApi.uploadJarsAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload jars (asynchronously)
Upload jars.
|
okhttp3.Call |
RestApi.uploadPyFilesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload pyfiles (asynchronously)
Upload pyfiles.
|
okhttp3.Call |
RestApi.uploadResourcesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload resources (asynchronously)
Upload resources.
|
Copyright © 2023. All rights reserved.