Package | Description |
---|---|
com.huawei.dli.restapi | |
com.huawei.dli.restapi.api |
Modifier and Type | Method and Description |
---|---|
okhttp3.Call |
ApiClient.buildCall(String path,
String method,
List<Pair> queryParams,
List<Pair> collectionQueryParams,
Object body,
Map<String,String> headerParams,
Map<String,Object> formParams,
String[] authNames,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build HTTP call with the given options.
|
okhttp3.Request |
ApiClient.buildRequest(String path,
String method,
List<Pair> queryParams,
List<Pair> collectionQueryParams,
Object body,
Map<String,String> headerParams,
Map<String,Object> formParams,
String[] authNames,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build an HTTP request with the given options.
|
Constructor and Description |
---|
ProgressRequestBody(okhttp3.RequestBody requestBody,
ProgressRequestBody.ProgressRequestListener progressListener) |
Modifier and Type | Method and Description |
---|---|
okhttp3.Call |
RestApi.alertResourceOrGroupOwnerCall(String projectId,
UpdateResourceOwner body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for alertResourceOrGroupOwner
|
okhttp3.Call |
RestApi.authorizeBucketCall(String projectId,
ObsBuckets obsBuckets,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for authorizeBucket
|
okhttp3.Call |
RestApi.cancelJob_0Call(String projectId,
String queueName,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for cancelJob_0
|
okhttp3.Call |
RestApi.cancelJobCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for cancelJob
|
okhttp3.Call |
RestApi.checkSQLCall(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for checkSQL
|
okhttp3.Call |
RestApi.commitUploadJobCall(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for commitUploadJob
|
okhttp3.Call |
RestApi.createBatchCall(String projectId,
Object body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createBatch
|
okhttp3.Call |
RestApi.createClusterCall(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createCluster
|
okhttp3.Call |
RestApi.createDatabaseCall(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createDatabase
|
okhttp3.Call |
RestApi.createDownloadJobCall(String projectId,
EmptyBody emptyBody,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createDownloadJob
|
okhttp3.Call |
RestApi.createFlinkJobTemplateCall(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createFlinkJobTemplate
|
okhttp3.Call |
RestApi.createObsSelectJobCall(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createObsSelectJob
|
okhttp3.Call |
RestApi.createQueueCall(String projectId,
QueueInfo queueInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createQueue
|
okhttp3.Call |
RestApi.createTableCall(String projectId,
String databaseName,
TableInfo tableInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createTable
|
okhttp3.Call |
RestApi.createTsdbCall(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createTsdb
|
okhttp3.Call |
RestApi.createUploadJobCall(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createUploadJob
|
okhttp3.Call |
RestApi.dataAuthorizeCall(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for dataAuthorize
|
okhttp3.Call |
RestApi.delBatchCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for delBatch
|
okhttp3.Call |
RestApi.deleteClusterCall(String projectId,
String clusterName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteCluster
|
okhttp3.Call |
RestApi.deleteDatabaseCall(String projectId,
String databaseName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteDatabase
|
okhttp3.Call |
RestApi.deleteFlinkJobCall(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteFlinkJob
|
okhttp3.Call |
RestApi.deleteFlinkJobTemplateCall(String projectId,
Long templateId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteFlinkJobTemplate
|
okhttp3.Call |
RestApi.deleteJobCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteJob
|
okhttp3.Call |
RestApi.deleteQueueCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteQueue
|
okhttp3.Call |
RestApi.deleteResourceCall(String projectId,
String resourceName,
String group,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteResource
|
okhttp3.Call |
RestApi.deleteTableCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteTable
|
okhttp3.Call |
RestApi.deleteTsdbCall(String projectId,
String tsdbId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteTsdb
|
okhttp3.Call |
RestApi.describeTableCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for describeTable
|
okhttp3.Call |
RestApi.execute_0Call(String projectId,
String queueName,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for execute_0
|
okhttp3.Call |
RestApi.executeCall(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for execute
|
okhttp3.Call |
RestApi.exportDataCall(String projectId,
ExportJobRequest exportInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for exportData
|
okhttp3.Call |
RestApi.getBatchInfoCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchInfo
|
okhttp3.Call |
RestApi.getBatchListCall(String projectId,
String xAuthToken,
String clusterName,
Integer from,
Integer size,
String jobId,
String jobName,
Long start,
Long end,
String order,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchList
|
okhttp3.Call |
RestApi.getBatchLogCall(String projectId,
String batchId,
String xAuthToken,
Integer from,
Integer size,
String type,
Integer index,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchLog
|
okhttp3.Call |
RestApi.getBatchStateCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchState
|
okhttp3.Call |
RestApi.getClusterCall(String projectId,
String clusterName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getCluster
|
okhttp3.Call |
RestApi.getFlinkApigSinksCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkApigSinks
|
okhttp3.Call |
RestApi.getFlinkJobDetailCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobDetail
|
okhttp3.Call |
RestApi.getFlinkJobExecuteGraphCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobExecuteGraph
|
okhttp3.Call |
RestApi.getFlinkJobsCall(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,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobs
|
okhttp3.Call |
RestApi.getFlinkJobsMetricsCall(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobsMetrics
|
okhttp3.Call |
RestApi.getFlinkJobTemplatesCall(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobTemplates
|
okhttp3.Call |
RestApi.getImportExportJobInfoCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getImportExportJobInfo
|
okhttp3.Call |
RestApi.getJobProgressCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobProgress
|
okhttp3.Call |
RestApi.getJobResult_0Call(String projectId,
String queueName,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobResult_0
|
okhttp3.Call |
RestApi.getJobResultCall(String projectId,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String queueName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobResult
|
okhttp3.Call |
RestApi.getJobStatusCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobStatus
|
okhttp3.Call |
RestApi.getResourceInfoCall(String projectId,
String resourceName,
String group,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getResourceInfo
|
okhttp3.Call |
RestApi.getSpecifiedQueueCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getSpecifiedQueue
|
okhttp3.Call |
TokenAuthApi.getTokenCall(TokenAuthInfo tokenAuthInfo,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getToken
|
okhttp3.Call |
RestApi.getTsdbByIdCall(String projectId,
Long tsdbId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getTsdbById
|
okhttp3.Call |
RestApi.getTsdbListCall(String projectId,
Integer offset,
Integer limit,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getTsdbList
|
okhttp3.Call |
RestApi.importDataCall(String projectId,
ImportJobRequest importExportInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for importData
|
okhttp3.Call |
RestApi.listAllDatabasesCall(String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllDatabases
|
okhttp3.Call |
RestApi.listAllJobsCall(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
Long start,
Long end,
String jobType,
String tags,
String queueName,
String owner,
String jobStatus,
String order,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllJobs
|
okhttp3.Call |
RestApi.listAllQueuesCall(String projectId,
String xAuthToken,
String queueType,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllQueues
|
okhttp3.Call |
RestApi.listAllTablesCall(String projectId,
String databaseName,
String xAuthToken,
String keyword,
Boolean withDetail,
Integer pageSize,
Integer currentPage,
String tableType,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllTables
|
okhttp3.Call |
RestApi.listClusterCall(String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listCluster
|
okhttp3.Call |
RestApi.listDatabaseUsersCall(String projectId,
String databaseName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listDatabaseUsers
|
okhttp3.Call |
RestApi.listQueueUsersCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listQueueUsers
|
okhttp3.Call |
RestApi.listResourcesCall(String projectId,
String xAuthToken,
String kind,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listResources
|
okhttp3.Call |
RestApi.listSqlJobsCall(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listSqlJobs
|
okhttp3.Call |
RestApi.listTableUserPrivilegesCall(String projectId,
String databaseName,
String tableName,
String userName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listTableUserPrivileges
|
okhttp3.Call |
RestApi.listTableUsersCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listTableUsers
|
okhttp3.Call |
RestApi.previewJobResultCall(String projectId,
String jobId,
String xAuthToken,
String queueName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for previewJobResult
|
okhttp3.Call |
RestApi.queueActionCall(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for queueAction
|
okhttp3.Call |
RestApi.runFlinkJobCall(String projectId,
RunFlinkJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runFlinkJob
|
okhttp3.Call |
RestApi.shareQueueCall(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for shareQueue
|
okhttp3.Call |
RestApi.showPartitionsCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
Integer offset,
Integer limit,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for showPartitions
|
okhttp3.Call |
RestApi.stopFlinkJobCall(String projectId,
StopFlinkJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for stopFlinkJob
|
okhttp3.Call |
RestApi.storeJobResultCall(String projectId,
String jobId,
String xAuthToken,
ExportCommonInfo exportCommonInfo,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for storeJobResult
|
okhttp3.Call |
RestApi.submitFlinkJarJobCall(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkJarJob
|
okhttp3.Call |
RestApi.submitFlinkSqlJobCall(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkSqlJob
|
okhttp3.Call |
RestApi.updateFlinkJarJobCall(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkJarJob
|
okhttp3.Call |
RestApi.updateFlinkJobTemplateCall(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkJobTemplate
|
okhttp3.Call |
RestApi.updateFlinkSqlJobCall(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkSqlJob
|
okhttp3.Call |
RestApi.updateTsdbCall(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateTsdb
|
okhttp3.Call |
RestApi.uploadFilesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadFiles
|
okhttp3.Call |
RestApi.uploadJarsCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadJars
|
okhttp3.Call |
RestApi.uploadPyFilesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadPyFiles
|
okhttp3.Call |
RestApi.uploadResourcesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadResources
|
Copyright © 2023. All rights reserved.