Package | Description |
---|---|
com.huawei.dli.restapi | |
com.huawei.dli.restapi.api |
Modifier and Type | Method and Description |
---|---|
void |
ApiCallback.onFailure(ApiException e,
int statusCode,
Map<String,List<String>> responseHeaders)
This is called when the API call fails.
|
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.
|
<T> T |
ApiClient.deserialize(okhttp3.Response response,
Type returnType)
Deserialize response body to Java object, according to the return type and
the Content-Type response header.
|
<T> ApiResponse<T> |
ApiClient.execute(okhttp3.Call call)
|
<T> ApiResponse<T> |
ApiClient.execute(okhttp3.Call call,
Type returnType)
Execute HTTP call and deserialize the HTTP response body into the given return type.
|
<T> T |
ApiClient.handleResponse(okhttp3.Response response,
Type returnType)
Handle the given response, return the deserialized object when the response is successful.
|
okhttp3.RequestBody |
ApiClient.serialize(Object obj,
String contentType)
Serialize the given Java object into request body according to the object's
class and the request Content-Type.
|
Modifier and Type | Method and Description |
---|---|
ResponseInfo |
RestApi.alertResourceOrGroupOwner(String projectId,
UpdateResourceOwner body,
String xAuthToken)
Modify owner of resource
Modify owner of resource.
|
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.alertResourceOrGroupOwnerCall(String projectId,
UpdateResourceOwner body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for alertResourceOrGroupOwner
|
ApiResponse<ResponseInfo> |
RestApi.alertResourceOrGroupOwnerWithHttpInfo(String projectId,
UpdateResourceOwner body,
String xAuthToken)
Modify owner of resource
Modify owner of resource.
|
GlobalResponse |
RestApi.authorizeBucket(String projectId,
ObsBuckets obsBuckets,
String xAuthToken)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等
|
okhttp3.Call |
RestApi.authorizeBucketAsync(String projectId,
ObsBuckets obsBuckets,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等 (asynchronously)
|
okhttp3.Call |
RestApi.authorizeBucketCall(String projectId,
ObsBuckets obsBuckets,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for authorizeBucket
|
ApiResponse<GlobalResponse> |
RestApi.authorizeBucketWithHttpInfo(String projectId,
ObsBuckets obsBuckets,
String xAuthToken)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等
|
ResponseInfo |
RestApi.cancelJob_0(String projectId,
String queueName,
String jobId,
String xAuthToken)
Cancel job
Canceling a job that has already been submitted can not be canceled if the job has been completed or failed.
|
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.cancelJob_0Call(String projectId,
String queueName,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for cancelJob_0
|
ApiResponse<ResponseInfo> |
RestApi.cancelJob_0WithHttpInfo(String projectId,
String queueName,
String jobId,
String xAuthToken)
Cancel job
Canceling a job that has already been submitted can not be canceled if the job has been completed or failed.
|
ResponseInfo |
RestApi.cancelJob(String projectId,
String jobId,
String xAuthToken)
Cancel job
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.cancelJobCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for cancelJob
|
ApiResponse<ResponseInfo> |
RestApi.cancelJobWithHttpInfo(String projectId,
String jobId,
String xAuthToken)
Cancel job
Canceling a job that has already been submitted can not be canceled if the job has been completed or failed.
|
ResponseJobInfo |
RestApi.checkSQL(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Check sql
Check the SQL grammar.
|
okhttp3.Call |
RestApi.checkSQLAsync(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Check sql (asynchronously)
Check the SQL grammar.
|
okhttp3.Call |
RestApi.checkSQLCall(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for checkSQL
|
ApiResponse<ResponseJobInfo> |
RestApi.checkSQLWithHttpInfo(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Check sql
Check the SQL grammar.
|
UploadCommitJobResult |
RestApi.commitUploadJob(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken)
Commit direct upload job
Commit direct upload job for upload data to DLI.
|
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.commitUploadJobCall(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for commitUploadJob
|
ApiResponse<UploadCommitJobResult> |
RestApi.commitUploadJobWithHttpInfo(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken)
Commit direct upload job
Commit direct upload job for upload data to DLI.
|
SessionInfo |
RestApi.createBatch(String projectId,
Object body,
String xAuthToken,
String USER_ID)
Create batch
Create batch.
|
okhttp3.Call |
RestApi.createBatchAsync(String projectId,
Object body,
String xAuthToken,
String USER_ID,
ApiCallback<SessionInfo> callback)
Create batch (asynchronously)
Create batch.
|
okhttp3.Call |
RestApi.createBatchCall(String projectId,
Object body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createBatch
|
ApiResponse<SessionInfo> |
RestApi.createBatchWithHttpInfo(String projectId,
Object body,
String xAuthToken,
String USER_ID)
Create batch
Create batch.
|
EmptyResponse |
RestApi.createCluster(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID)
Create cluster
Create cluster.
|
okhttp3.Call |
RestApi.createClusterAsync(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID,
ApiCallback<EmptyResponse> callback)
Create cluster (asynchronously)
Create cluster.
|
okhttp3.Call |
RestApi.createClusterCall(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createCluster
|
ApiResponse<EmptyResponse> |
RestApi.createClusterWithHttpInfo(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID)
Create cluster
Create cluster.
|
ResponseInfo |
RestApi.createDatabase(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken)
Create database
create a database
|
okhttp3.Call |
RestApi.createDatabaseAsync(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Create database (asynchronously)
create a database
|
okhttp3.Call |
RestApi.createDatabaseCall(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createDatabase
|
ApiResponse<ResponseInfo> |
RestApi.createDatabaseWithHttpInfo(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken)
Create database
create a database
|
DownloadCreateJobResult |
RestApi.createDownloadJob(String projectId,
EmptyBody emptyBody,
String xAuthToken)
Create direct download job
Create direct download job for download data from DLI.
|
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.createDownloadJobCall(String projectId,
EmptyBody emptyBody,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createDownloadJob
|
ApiResponse<DownloadCreateJobResult> |
RestApi.createDownloadJobWithHttpInfo(String projectId,
EmptyBody emptyBody,
String xAuthToken)
Create direct download job
Create direct download job for download data from DLI.
|
FlinkJobTemplateCreateResponse |
RestApi.createFlinkJobTemplate(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken)
创建作业模板
Create job template on Data lake insight
|
okhttp3.Call |
RestApi.createFlinkJobTemplateAsync(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken,
ApiCallback<FlinkJobTemplateCreateResponse> callback)
创建作业模板 (asynchronously)
Create job template on Data lake insight
|
okhttp3.Call |
RestApi.createFlinkJobTemplateCall(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createFlinkJobTemplate
|
ApiResponse<FlinkJobTemplateCreateResponse> |
RestApi.createFlinkJobTemplateWithHttpInfo(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken)
创建作业模板
Create job template on Data lake insight
|
ObsSelectJobResult |
RestApi.createObsSelectJob(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken)
Create Obs select job
Create Obs select job to DLI.
|
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.createObsSelectJobCall(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createObsSelectJob
|
ApiResponse<ObsSelectJobResult> |
RestApi.createObsSelectJobWithHttpInfo(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken)
Create Obs select job
Create Obs select job to DLI.
|
ResponseQueueInfo |
RestApi.createQueue(String projectId,
QueueInfo queueInfo,
String xAuthToken)
Create queue
Create a queue that will bind user-specified computing resources.
|
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.createQueueCall(String projectId,
QueueInfo queueInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createQueue
|
ApiResponse<ResponseQueueInfo> |
RestApi.createQueueWithHttpInfo(String projectId,
QueueInfo queueInfo,
String xAuthToken)
Create queue
Create a queue that will bind user-specified computing resources.
|
ResponseInfo |
RestApi.createTable(String projectId,
String databaseName,
TableInfo tableInfo,
String xAuthToken)
Create a new table
Data location:DLI and OBS,OBS must set data_location and data_type parameter
|
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.createTableCall(String projectId,
String databaseName,
TableInfo tableInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createTable
|
ApiResponse<ResponseInfo> |
RestApi.createTableWithHttpInfo(String projectId,
String databaseName,
TableInfo tableInfo,
String xAuthToken)
Create a new table
Data location:DLI and OBS,OBS must set data_location and data_type parameter
|
CreateTsdbResp |
RestApi.createTsdb(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken)
创建时序数据库配置信息
|
okhttp3.Call |
RestApi.createTsdbAsync(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken,
ApiCallback<CreateTsdbResp> callback)
创建时序数据库配置信息 (asynchronously)
|
okhttp3.Call |
RestApi.createTsdbCall(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createTsdb
|
ApiResponse<CreateTsdbResp> |
RestApi.createTsdbWithHttpInfo(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken)
创建时序数据库配置信息
|
UploadCreateJobResult |
RestApi.createUploadJob(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken)
Create direct upload job
Create direct upload job for upload data to DLI.
|
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.createUploadJobCall(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createUploadJob
|
ApiResponse<UploadCreateJobResult> |
RestApi.createUploadJobWithHttpInfo(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken)
Create direct upload job
Create direct upload job for upload data to DLI.
|
ResponseInfo |
RestApi.dataAuthorize(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken)
List queue users
Privilege data permissions to the database or data table to other specified users.
|
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.dataAuthorizeCall(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for dataAuthorize
|
ApiResponse<ResponseInfo> |
RestApi.dataAuthorizeWithHttpInfo(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken)
List queue users
Privilege data permissions to the database or data table to other specified users.
|
MessageInfo |
RestApi.delBatch(String projectId,
String batchId,
String xAuthToken)
Delete specified batch
Delete specified batch.
|
okhttp3.Call |
RestApi.delBatchAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<MessageInfo> callback)
Delete specified batch (asynchronously)
Delete specified batch.
|
okhttp3.Call |
RestApi.delBatchCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for delBatch
|
ApiResponse<MessageInfo> |
RestApi.delBatchWithHttpInfo(String projectId,
String batchId,
String xAuthToken)
Delete specified batch
Delete specified batch.
|
EmptyResponse |
RestApi.deleteCluster(String projectId,
String clusterName,
String xAuthToken)
Delete cluster
Delete cluster.
|
okhttp3.Call |
RestApi.deleteClusterAsync(String projectId,
String clusterName,
String xAuthToken,
ApiCallback<EmptyResponse> callback)
Delete cluster (asynchronously)
Delete cluster.
|
okhttp3.Call |
RestApi.deleteClusterCall(String projectId,
String clusterName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteCluster
|
ApiResponse<EmptyResponse> |
RestApi.deleteClusterWithHttpInfo(String projectId,
String clusterName,
String xAuthToken)
Delete cluster
Delete cluster.
|
ResponseInfo |
RestApi.deleteDatabase(String projectId,
String databaseName,
String xAuthToken)
Delete database
Delete database by database name.
|
okhttp3.Call |
RestApi.deleteDatabaseAsync(String projectId,
String databaseName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete database (asynchronously)
Delete database by database name.
|
okhttp3.Call |
RestApi.deleteDatabaseCall(String projectId,
String databaseName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteDatabase
|
ApiResponse<ResponseInfo> |
RestApi.deleteDatabaseWithHttpInfo(String projectId,
String databaseName,
String xAuthToken)
Delete database
Delete database by database name.
|
List<GlobalBatchResponse> |
RestApi.deleteFlinkJob(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken)
批量删除作业
|
okhttp3.Call |
RestApi.deleteFlinkJobAsync(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
批量删除作业 (asynchronously)
|
okhttp3.Call |
RestApi.deleteFlinkJobCall(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteFlinkJob
|
FlinkJobTemplateDeleteResponse |
RestApi.deleteFlinkJobTemplate(String projectId,
Long templateId,
String xAuthToken)
删除作业模板
当前模板被引用也允许删除模板
|
okhttp3.Call |
RestApi.deleteFlinkJobTemplateAsync(String projectId,
Long templateId,
String xAuthToken,
ApiCallback<FlinkJobTemplateDeleteResponse> callback)
删除作业模板 (asynchronously)
当前模板被引用也允许删除模板
|
okhttp3.Call |
RestApi.deleteFlinkJobTemplateCall(String projectId,
Long templateId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteFlinkJobTemplate
|
ApiResponse<FlinkJobTemplateDeleteResponse> |
RestApi.deleteFlinkJobTemplateWithHttpInfo(String projectId,
Long templateId,
String xAuthToken)
删除作业模板
当前模板被引用也允许删除模板
|
ApiResponse<List<GlobalBatchResponse>> |
RestApi.deleteFlinkJobWithHttpInfo(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken)
批量删除作业
|
GlobalResponse |
RestApi.deleteJob(String projectId,
Long jobId,
String xAuthToken)
删除作业
删除任何状态的作业
|
okhttp3.Call |
RestApi.deleteJobAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
删除作业 (asynchronously)
删除任何状态的作业
|
okhttp3.Call |
RestApi.deleteJobCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteJob
|
ApiResponse<GlobalResponse> |
RestApi.deleteJobWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
删除作业
删除任何状态的作业
|
ResponseInfo |
RestApi.deleteQueue(String projectId,
String queueName,
String xAuthToken)
Delete queue
Delete the specified queue.
|
okhttp3.Call |
RestApi.deleteQueueAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete queue (asynchronously)
Delete the specified queue.
|
okhttp3.Call |
RestApi.deleteQueueCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteQueue
|
ApiResponse<ResponseInfo> |
RestApi.deleteQueueWithHttpInfo(String projectId,
String queueName,
String xAuthToken)
Delete queue
Delete the specified queue.
|
EmptyResponse |
RestApi.deleteResource(String projectId,
String resourceName,
String group,
String xAuthToken)
Delete specified resource
Delete specified resource.
|
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.deleteResourceCall(String projectId,
String resourceName,
String group,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteResource
|
ApiResponse<EmptyResponse> |
RestApi.deleteResourceWithHttpInfo(String projectId,
String resourceName,
String group,
String xAuthToken)
Delete specified resource
Delete specified resource.
|
ResponseInfo |
RestApi.deleteTable(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Delete table
Delete the specified table.
|
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.deleteTableCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteTable
|
ApiResponse<ResponseInfo> |
RestApi.deleteTableWithHttpInfo(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Delete table
Delete the specified table.
|
GlobalResponse |
RestApi.deleteTsdb(String projectId,
String tsdbId,
String xAuthToken)
删除时序数据库配置信息
删除时序数据库配置信息
|
okhttp3.Call |
RestApi.deleteTsdbAsync(String projectId,
String tsdbId,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
删除时序数据库配置信息 (asynchronously)
删除时序数据库配置信息
|
okhttp3.Call |
RestApi.deleteTsdbCall(String projectId,
String tsdbId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteTsdb
|
ApiResponse<GlobalResponse> |
RestApi.deleteTsdbWithHttpInfo(String projectId,
String tsdbId,
String xAuthToken)
删除时序数据库配置信息
删除时序数据库配置信息
|
ColumnResult |
RestApi.describeTable(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Describe Table
Describes the metadata information for the specified table.
|
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.describeTableCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for describeTable
|
ApiResponse<ColumnResult> |
RestApi.describeTableWithHttpInfo(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Describe Table
Describes the metadata information for the specified table.
|
ResponseJobInfo |
RestApi.execute_0(String projectId,
String queueName,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Submit job
This API is used to submit jobs to the cluster by executing SQL statements.
|
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.execute_0Call(String projectId,
String queueName,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for execute_0
|
ApiResponse<ResponseJobInfo> |
RestApi.execute_0WithHttpInfo(String projectId,
String queueName,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Submit job
This API is used to submit jobs to the cluster by executing SQL statements.
|
ResponseJobInfo |
RestApi.execute(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Submit job
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.executeCall(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for execute
|
ApiResponse<ResponseJobInfo> |
RestApi.executeWithHttpInfo(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Submit job
This API is used to submit jobs to the cluster by executing SQL statements.
|
ResponseJobInfo |
RestApi.exportData(String projectId,
ExportJobRequest exportInfo,
String xAuthToken)
Export data
Export the data to a file.
|
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.exportDataCall(String projectId,
ExportJobRequest exportInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for exportData
|
ApiResponse<ResponseJobInfo> |
RestApi.exportDataWithHttpInfo(String projectId,
ExportJobRequest exportInfo,
String xAuthToken)
Export data
Export the data to a file.
|
SessionInfo |
RestApi.getBatchInfo(String projectId,
String batchId,
String xAuthToken)
List specified batch
List specified batch.
|
okhttp3.Call |
RestApi.getBatchInfoAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<SessionInfo> callback)
List specified batch (asynchronously)
List specified batch.
|
okhttp3.Call |
RestApi.getBatchInfoCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchInfo
|
ApiResponse<SessionInfo> |
RestApi.getBatchInfoWithHttpInfo(String projectId,
String batchId,
String xAuthToken)
List specified batch
List specified batch.
|
SessionInfos |
RestApi.getBatchList(String projectId,
String xAuthToken,
String clusterName,
Integer from,
Integer size,
String jobId,
String jobName,
Long start,
Long end,
String order)
List all batchs
List all batchs.
|
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.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
|
ApiResponse<SessionInfos> |
RestApi.getBatchListWithHttpInfo(String projectId,
String xAuthToken,
String clusterName,
Integer from,
Integer size,
String jobId,
String jobName,
Long start,
Long end,
String order)
List all batchs
List all batchs.
|
SessionLog |
RestApi.getBatchLog(String projectId,
String batchId,
String xAuthToken,
Integer from,
Integer size,
String type,
Integer index)
Get specified batch log
Get specified batch log.
|
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.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
|
ApiResponse<SessionLog> |
RestApi.getBatchLogWithHttpInfo(String projectId,
String batchId,
String xAuthToken,
Integer from,
Integer size,
String type,
Integer index)
Get specified batch log
Get specified batch log.
|
SessionState |
RestApi.getBatchState(String projectId,
String batchId,
String xAuthToken)
Get specified session state
Get specified session state.
|
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.getBatchStateCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchState
|
ApiResponse<SessionState> |
RestApi.getBatchStateWithHttpInfo(String projectId,
String batchId,
String xAuthToken)
Get specified session state
Get specified session state.
|
ClusterInfo |
RestApi.getCluster(String projectId,
String clusterName,
String xAuthToken)
List specified cluster
List specified cluster.
|
okhttp3.Call |
RestApi.getClusterAsync(String projectId,
String clusterName,
String xAuthToken,
ApiCallback<ClusterInfo> callback)
List specified cluster (asynchronously)
List specified cluster.
|
okhttp3.Call |
RestApi.getClusterCall(String projectId,
String clusterName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getCluster
|
ApiResponse<ClusterInfo> |
RestApi.getClusterWithHttpInfo(String projectId,
String clusterName,
String xAuthToken)
List specified cluster
List specified cluster.
|
FlinkJobApigSinksResponse |
RestApi.getFlinkApigSinks(String projectId,
Long jobId,
String xAuthToken)
查询作业apig网关服务访问地址
The apig sinks is json format.
|
okhttp3.Call |
RestApi.getFlinkApigSinksAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<FlinkJobApigSinksResponse> callback)
查询作业apig网关服务访问地址 (asynchronously)
The apig sinks is json format.
|
okhttp3.Call |
RestApi.getFlinkApigSinksCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkApigSinks
|
ApiResponse<FlinkJobApigSinksResponse> |
RestApi.getFlinkApigSinksWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
查询作业apig网关服务访问地址
The apig sinks is json format.
|
GetFlinkJobDetailResponse |
RestApi.getFlinkJobDetail(String projectId,
Long jobId,
String xAuthToken)
查询作业详情
Get job detail information.
|
okhttp3.Call |
RestApi.getFlinkJobDetailAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<GetFlinkJobDetailResponse> callback)
查询作业详情 (asynchronously)
Get job detail information.
|
okhttp3.Call |
RestApi.getFlinkJobDetailCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobDetail
|
ApiResponse<GetFlinkJobDetailResponse> |
RestApi.getFlinkJobDetailWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
查询作业详情
Get job detail information.
|
FlinkJobExecutePlanResponse |
RestApi.getFlinkJobExecuteGraph(String projectId,
Long jobId,
String xAuthToken)
查询作业执行计划图
The execution graph is json format.
|
okhttp3.Call |
RestApi.getFlinkJobExecuteGraphAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<FlinkJobExecutePlanResponse> callback)
查询作业执行计划图 (asynchronously)
The execution graph is json format.
|
okhttp3.Call |
RestApi.getFlinkJobExecuteGraphCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobExecuteGraph
|
ApiResponse<FlinkJobExecutePlanResponse> |
RestApi.getFlinkJobExecuteGraphWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
查询作业执行计划图
The execution graph is json format.
|
QueryFlinkJobListResponse |
RestApi.getFlinkJobs(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)
查询作业列表
作业列表查询, 支持以下参数: name, status, show_detail, cursor, next, limit, order, root_job_id.
|
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.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
|
QueryFlinkJobMetricsResponse |
RestApi.getFlinkJobsMetrics(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken)
查询作业监控信息
查询作业监控信息, 支持同时查询多个作业监控信息
|
okhttp3.Call |
RestApi.getFlinkJobsMetricsAsync(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken,
ApiCallback<QueryFlinkJobMetricsResponse> callback)
查询作业监控信息 (asynchronously)
查询作业监控信息, 支持同时查询多个作业监控信息
|
okhttp3.Call |
RestApi.getFlinkJobsMetricsCall(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobsMetrics
|
ApiResponse<QueryFlinkJobMetricsResponse> |
RestApi.getFlinkJobsMetricsWithHttpInfo(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken)
查询作业监控信息
查询作业监控信息, 支持同时查询多个作业监控信息
|
ApiResponse<QueryFlinkJobListResponse> |
RestApi.getFlinkJobsWithHttpInfo(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)
查询作业列表
作业列表查询, 支持以下参数: name, status, show_detail, cursor, next, limit, order, root_job_id.
|
FlinkJobTemplateListResponse |
RestApi.getFlinkJobTemplates(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order)
查询作业模板列表
|
okhttp3.Call |
RestApi.getFlinkJobTemplatesAsync(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order,
ApiCallback<FlinkJobTemplateListResponse> callback)
查询作业模板列表 (asynchronously)
|
okhttp3.Call |
RestApi.getFlinkJobTemplatesCall(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobTemplates
|
ApiResponse<FlinkJobTemplateListResponse> |
RestApi.getFlinkJobTemplatesWithHttpInfo(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order)
查询作业模板列表
|
DetailResult |
RestApi.getImportExportJobInfo(String projectId,
String jobId,
String xAuthToken)
Import and Export detail
Query the details of imported and exported jobs, such as the job's databaseName, tableName, file size, and export mode.
|
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.getImportExportJobInfoCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getImportExportJobInfo
|
ApiResponse<DetailResult> |
RestApi.getImportExportJobInfoWithHttpInfo(String projectId,
String jobId,
String xAuthToken)
Import and Export detail
Query the details of imported and exported jobs, such as the job's databaseName, tableName, file size, and export mode.
|
JobProgressResult |
RestApi.getJobProgress(String projectId,
String jobId,
String xAuthToken)
Get job progress
Get job progress
|
okhttp3.Call |
RestApi.getJobProgressAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<JobProgressResult> callback)
Get job progress (asynchronously)
Get job progress
|
okhttp3.Call |
RestApi.getJobProgressCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobProgress
|
ApiResponse<JobProgressResult> |
RestApi.getJobProgressWithHttpInfo(String projectId,
String jobId,
String xAuthToken)
Get job progress
Get job progress
|
JobResult |
RestApi.getJobResult_0(String projectId,
String queueName,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage)
Get job result
After the job executing the SQL query is completed, review the result of the job execution.
|
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.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
|
ApiResponse<JobResult> |
RestApi.getJobResult_0WithHttpInfo(String projectId,
String queueName,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage)
Get job result
After the job executing the SQL query is completed, review the result of the job execution.
|
JobResult |
RestApi.getJobResult(String projectId,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String queueName)
Get job result
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.getJobResultCall(String projectId,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String queueName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobResult
|
ApiResponse<JobResult> |
RestApi.getJobResultWithHttpInfo(String projectId,
String jobId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String queueName)
Get job result
After the job executing the SQL query is completed, review the result of the job execution.
|
StatusResult |
RestApi.getJobStatus(String projectId,
String jobId,
String xAuthToken)
Get job status
Get job status after job submission.
|
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.getJobStatusCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobStatus
|
ApiResponse<StatusResult> |
RestApi.getJobStatusWithHttpInfo(String projectId,
String jobId,
String xAuthToken)
Get job status
Get job status after job submission.
|
PkgResourceInfo |
RestApi.getResourceInfo(String projectId,
String resourceName,
String group,
String xAuthToken)
List specified resource
List specified resource.
|
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.getResourceInfoCall(String projectId,
String resourceName,
String group,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getResourceInfo
|
ApiResponse<PkgResourceInfo> |
RestApi.getResourceInfoWithHttpInfo(String projectId,
String resourceName,
String group,
String xAuthToken)
List specified resource
List specified resource.
|
QueueInfo |
RestApi.getSpecifiedQueue(String projectId,
String queueName,
String xAuthToken)
Get queue
Get the specified queue.
|
okhttp3.Call |
RestApi.getSpecifiedQueueAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<QueueInfo> callback)
Get queue (asynchronously)
Get the specified queue.
|
okhttp3.Call |
RestApi.getSpecifiedQueueCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getSpecifiedQueue
|
ApiResponse<QueueInfo> |
RestApi.getSpecifiedQueueWithHttpInfo(String projectId,
String queueName,
String xAuthToken)
Get queue
Get the specified queue.
|
TokenAuthResponse |
TokenAuthApi.getToken(TokenAuthInfo tokenAuthInfo)
get token
get token for authentication
|
okhttp3.Call |
TokenAuthApi.getTokenAsync(TokenAuthInfo tokenAuthInfo,
ApiCallback<TokenAuthResponse> callback)
get token (asynchronously)
get token for authentication
|
okhttp3.Call |
TokenAuthApi.getTokenCall(TokenAuthInfo tokenAuthInfo,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getToken
|
ApiResponse<TokenAuthResponse> |
TokenAuthApi.getTokenWithHttpInfo(TokenAuthInfo tokenAuthInfo)
get token
get token for authentication
|
GetTsdbByIdResp |
RestApi.getTsdbById(String projectId,
Long tsdbId,
String xAuthToken)
查询时序数据库配置信息详情
根据时序数据库ID,查询时序数据库详情
|
okhttp3.Call |
RestApi.getTsdbByIdAsync(String projectId,
Long tsdbId,
String xAuthToken,
ApiCallback<GetTsdbByIdResp> callback)
查询时序数据库配置信息详情 (asynchronously)
根据时序数据库ID,查询时序数据库详情
|
okhttp3.Call |
RestApi.getTsdbByIdCall(String projectId,
Long tsdbId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getTsdbById
|
ApiResponse<GetTsdbByIdResp> |
RestApi.getTsdbByIdWithHttpInfo(String projectId,
Long tsdbId,
String xAuthToken)
查询时序数据库配置信息详情
根据时序数据库ID,查询时序数据库详情
|
GetTsdbListResp |
RestApi.getTsdbList(String projectId,
Integer offset,
Integer limit,
String xAuthToken)
查询时序数据库配置信息列表
|
okhttp3.Call |
RestApi.getTsdbListAsync(String projectId,
Integer offset,
Integer limit,
String xAuthToken,
ApiCallback<GetTsdbListResp> callback)
查询时序数据库配置信息列表 (asynchronously)
|
okhttp3.Call |
RestApi.getTsdbListCall(String projectId,
Integer offset,
Integer limit,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getTsdbList
|
ApiResponse<GetTsdbListResp> |
RestApi.getTsdbListWithHttpInfo(String projectId,
Integer offset,
Integer limit,
String xAuthToken)
查询时序数据库配置信息列表
|
ResponseJobInfo |
RestApi.importData(String projectId,
ImportJobRequest importExportInfo,
String xAuthToken)
Import data
Importing data from a file into a DLI table currently only supports importing data from OBS into DLI.
|
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.importDataCall(String projectId,
ImportJobRequest importExportInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for importData
|
ApiResponse<ResponseJobInfo> |
RestApi.importDataWithHttpInfo(String projectId,
ImportJobRequest importExportInfo,
String xAuthToken)
Import data
Importing data from a file into a DLI table currently only supports importing data from OBS into DLI.
|
DatabaseResult |
RestApi.listAllDatabases(String projectId,
String xAuthToken)
List all databases
List all databases info,include owner and table_number.
|
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.listAllDatabasesCall(String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllDatabases
|
ApiResponse<DatabaseResult> |
RestApi.listAllDatabasesWithHttpInfo(String projectId,
String xAuthToken)
List all databases
List all databases info,include owner and table_number.
|
JobListResult |
RestApi.listAllJobs(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
Long start,
Long end,
String jobType,
String tags,
String queueName,
String owner,
String jobStatus,
String order)
List all jobs
List all jobs
|
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.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
|
ApiResponse<JobListResult> |
RestApi.listAllJobsWithHttpInfo(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
Long start,
Long end,
String jobType,
String tags,
String queueName,
String owner,
String jobStatus,
String order)
List all jobs
List all jobs
|
QueueResult |
RestApi.listAllQueues(String projectId,
String xAuthToken,
String queueType)
List all queues
List all the queues under the project.
|
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.listAllQueuesCall(String projectId,
String xAuthToken,
String queueType,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllQueues
|
ApiResponse<QueueResult> |
RestApi.listAllQueuesWithHttpInfo(String projectId,
String xAuthToken,
String queueType)
List all queues
List all the queues under the project.
|
TableListResult |
RestApi.listAllTables(String projectId,
String databaseName,
String xAuthToken,
String keyword,
Boolean withDetail,
Integer pageSize,
Integer currentPage,
String tableType)
List all tables
Query the specified database under the filter conditions or all of the table information.
|
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.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
|
ApiResponse<TableListResult> |
RestApi.listAllTablesWithHttpInfo(String projectId,
String databaseName,
String xAuthToken,
String keyword,
Boolean withDetail,
Integer pageSize,
Integer currentPage,
String tableType)
List all tables
Query the specified database under the filter conditions or all of the table information.
|
ClusterInfos |
RestApi.listCluster(String projectId,
String xAuthToken)
List all clusters
List all clusters.
|
okhttp3.Call |
RestApi.listClusterAsync(String projectId,
String xAuthToken,
ApiCallback<ClusterInfos> callback)
List all clusters (asynchronously)
List all clusters.
|
okhttp3.Call |
RestApi.listClusterCall(String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listCluster
|
ApiResponse<ClusterInfos> |
RestApi.listClusterWithHttpInfo(String projectId,
String xAuthToken)
List all clusters
List all clusters.
|
PrivilegeResult |
RestApi.listDatabaseUsers(String projectId,
String databaseName,
String xAuthToken)
List Database Users
View the current database has permission to use or access all user names.
|
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.listDatabaseUsersCall(String projectId,
String databaseName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listDatabaseUsers
|
ApiResponse<PrivilegeResult> |
RestApi.listDatabaseUsersWithHttpInfo(String projectId,
String databaseName,
String xAuthToken)
List Database Users
View the current database has permission to use or access all user names.
|
PrivilegeResult |
RestApi.listQueueUsers(String projectId,
String queueName,
String xAuthToken)
List queue users
Queries all the user names of the specified queue that can be used.
|
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.listQueueUsersCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listQueueUsers
|
ApiResponse<PrivilegeResult> |
RestApi.listQueueUsersWithHttpInfo(String projectId,
String queueName,
String xAuthToken)
List queue users
Queries all the user names of the specified queue that can be used.
|
ResourceInfos |
RestApi.listResources(String projectId,
String xAuthToken,
String kind)
List all resources
List all resources.
|
okhttp3.Call |
RestApi.listResourcesAsync(String projectId,
String xAuthToken,
String kind,
ApiCallback<ResourceInfos> callback)
List all resources (asynchronously)
List all resources.
|
okhttp3.Call |
RestApi.listResourcesCall(String projectId,
String xAuthToken,
String kind,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listResources
|
ApiResponse<ResourceInfos> |
RestApi.listResourcesWithHttpInfo(String projectId,
String xAuthToken,
String kind)
List all resources
List all resources.
|
JobListResult |
RestApi.listSqlJobs(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags)
List all sql jobs
List all sql jobs
|
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.listSqlJobsCall(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listSqlJobs
|
ApiResponse<JobListResult> |
RestApi.listSqlJobsWithHttpInfo(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags)
List all sql jobs
List all sql jobs
|
PrivilegeResult |
RestApi.listTableUserPrivileges(String projectId,
String databaseName,
String tableName,
String userName,
String xAuthToken)
List Table User Privileges
Query the specified user's privileges list on the table.
|
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.listTableUserPrivilegesCall(String projectId,
String databaseName,
String tableName,
String userName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listTableUserPrivileges
|
ApiResponse<PrivilegeResult> |
RestApi.listTableUserPrivilegesWithHttpInfo(String projectId,
String databaseName,
String tableName,
String userName,
String xAuthToken)
List Table User Privileges
Query the specified user's privileges list on the table.
|
PrivilegeResult |
RestApi.listTableUsers(String projectId,
String databaseName,
String tableName,
String xAuthToken)
List Table Users
View all users who have access to the columns of the specified table or 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.listTableUsersCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listTableUsers
|
ApiResponse<PrivilegeResult> |
RestApi.listTableUsersWithHttpInfo(String projectId,
String databaseName,
String tableName,
String xAuthToken)
List Table Users
View all users who have access to the columns of the specified table or table.
|
JobResult |
RestApi.previewJobResult(String projectId,
String jobId,
String xAuthToken,
String queueName)
Get job result
After the job executing the SQL query is completed, review the result of the job execution.
|
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.previewJobResultCall(String projectId,
String jobId,
String xAuthToken,
String queueName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for previewJobResult
|
ApiResponse<JobResult> |
RestApi.previewJobResultWithHttpInfo(String projectId,
String jobId,
String xAuthToken,
String queueName)
Get job result
After the job executing the SQL query is completed, review the result of the job execution.
|
QueueActionResponse |
RestApi.queueAction(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken)
队列操作
|
okhttp3.Call |
RestApi.queueActionAsync(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken,
ApiCallback<QueueActionResponse> callback)
队列操作 (asynchronously)
|
okhttp3.Call |
RestApi.queueActionCall(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for queueAction
|
ApiResponse<QueueActionResponse> |
RestApi.queueActionWithHttpInfo(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken)
队列操作
|
List<GlobalBatchResponse> |
RestApi.runFlinkJob(String projectId,
RunFlinkJobRequest body,
String xAuthToken)
运行作业
触发运行作业
|
okhttp3.Call |
RestApi.runFlinkJobAsync(String projectId,
RunFlinkJobRequest body,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
运行作业 (asynchronously)
触发运行作业
|
okhttp3.Call |
RestApi.runFlinkJobCall(String projectId,
RunFlinkJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runFlinkJob
|
ApiResponse<List<GlobalBatchResponse>> |
RestApi.runFlinkJobWithHttpInfo(String projectId,
RunFlinkJobRequest body,
String xAuthToken)
运行作业
触发运行作业
|
ResponseInfo |
RestApi.shareQueue(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken)
Share queues
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.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.shareQueueCall(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for shareQueue
|
ApiResponse<ResponseInfo> |
RestApi.shareQueueWithHttpInfo(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken)
Share queues
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.
|
PartitionResult |
RestApi.showPartitions(String projectId,
String databaseName,
String tableName,
String xAuthToken,
Integer offset,
Integer limit)
Show partition information
Describes the partition information for the specified table.
|
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.showPartitionsCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
Integer offset,
Integer limit,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for showPartitions
|
ApiResponse<PartitionResult> |
RestApi.showPartitionsWithHttpInfo(String projectId,
String databaseName,
String tableName,
String xAuthToken,
Integer offset,
Integer limit)
Show partition information
Describes the partition information for the specified table.
|
List<GlobalBatchResponse> |
RestApi.stopFlinkJob(String projectId,
StopFlinkJobRequest body,
String xAuthToken)
停止作业
|
okhttp3.Call |
RestApi.stopFlinkJobAsync(String projectId,
StopFlinkJobRequest body,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
停止作业 (asynchronously)
|
okhttp3.Call |
RestApi.stopFlinkJobCall(String projectId,
StopFlinkJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for stopFlinkJob
|
ApiResponse<List<GlobalBatchResponse>> |
RestApi.stopFlinkJobWithHttpInfo(String projectId,
StopFlinkJobRequest body,
String xAuthToken)
停止作业
|
ResponseJobInfo |
RestApi.storeJobResult(String projectId,
String jobId,
String xAuthToken,
ExportCommonInfo exportCommonInfo)
Export job result
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.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.storeJobResultCall(String projectId,
String jobId,
String xAuthToken,
ExportCommonInfo exportCommonInfo,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for storeJobResult
|
ApiResponse<ResponseJobInfo> |
RestApi.storeJobResultWithHttpInfo(String projectId,
String jobId,
String xAuthToken,
ExportCommonInfo exportCommonInfo)
Export job result
Export the results of the SQL statement to the OBS object store and only support the export of query results for \"QUERY\" type jobs.
|
JobStatusResponse |
RestApi.submitFlinkJarJob(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.submitFlinkJarJobAsync(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
创建一个用户自定义Flink作业 (asynchronously)
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.submitFlinkJarJobCall(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkJarJob
|
ApiResponse<JobStatusResponse> |
RestApi.submitFlinkJarJobWithHttpInfo(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
JobStatusResponse |
RestApi.submitFlinkSqlJob(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken)
提交流式SQL作业到DLI服务
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
okhttp3.Call |
RestApi.submitFlinkSqlJobAsync(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
提交流式SQL作业到DLI服务 (asynchronously)
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
okhttp3.Call |
RestApi.submitFlinkSqlJobCall(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkSqlJob
|
ApiResponse<JobStatusResponse> |
RestApi.submitFlinkSqlJobWithHttpInfo(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken)
提交流式SQL作业到DLI服务
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
JobUpdateResponse |
RestApi.updateFlinkJarJob(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken)
更新用户自定义Flink作业
目前仅支持Jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.updateFlinkJarJobAsync(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新用户自定义Flink作业 (asynchronously)
目前仅支持Jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.updateFlinkJarJobCall(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkJarJob
|
ApiResponse<JobUpdateResponse> |
RestApi.updateFlinkJarJobWithHttpInfo(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken)
更新用户自定义Flink作业
目前仅支持Jar格式, 运行在独享集群中
|
GlobalResponse |
RestApi.updateFlinkJobTemplate(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken)
更新作业模板
Update job template on Data lake insight
|
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.updateFlinkJobTemplateCall(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkJobTemplate
|
ApiResponse<GlobalResponse> |
RestApi.updateFlinkJobTemplateWithHttpInfo(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken)
更新作业模板
Update job template on Data lake insight
|
JobUpdateResponse |
RestApi.updateFlinkSqlJob(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken)
更新流式SQL作业
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
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.updateFlinkSqlJobCall(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkSqlJob
|
ApiResponse<JobUpdateResponse> |
RestApi.updateFlinkSqlJobWithHttpInfo(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken)
更新流式SQL作业
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
GlobalResponse |
RestApi.updateTsdb(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken)
修改时序数据库配置信息
修改时序数据库配置信息
|
okhttp3.Call |
RestApi.updateTsdbAsync(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
修改时序数据库配置信息 (asynchronously)
修改时序数据库配置信息
|
okhttp3.Call |
RestApi.updateTsdbCall(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateTsdb
|
ApiResponse<GlobalResponse> |
RestApi.updateTsdbWithHttpInfo(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken)
修改时序数据库配置信息
修改时序数据库配置信息
|
ResourceMsg |
RestApi.uploadFiles(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload files
Upload files.
|
okhttp3.Call |
RestApi.uploadFilesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload files (asynchronously)
Upload files.
|
okhttp3.Call |
RestApi.uploadFilesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadFiles
|
ApiResponse<ResourceMsg> |
RestApi.uploadFilesWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload files
Upload files.
|
ResourceMsg |
RestApi.uploadJars(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload jars
Upload jars.
|
okhttp3.Call |
RestApi.uploadJarsAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload jars (asynchronously)
Upload jars.
|
okhttp3.Call |
RestApi.uploadJarsCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadJars
|
ApiResponse<ResourceMsg> |
RestApi.uploadJarsWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload jars
Upload jars.
|
ResourceMsg |
RestApi.uploadPyFiles(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload pyfiles
Upload pyfiles.
|
okhttp3.Call |
RestApi.uploadPyFilesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload pyfiles (asynchronously)
Upload pyfiles.
|
okhttp3.Call |
RestApi.uploadPyFilesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadPyFiles
|
ApiResponse<ResourceMsg> |
RestApi.uploadPyFilesWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload pyfiles
Upload pyfiles.
|
ResourceMsg |
RestApi.uploadResources(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload resources
Upload resources.
|
okhttp3.Call |
RestApi.uploadResourcesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload resources (asynchronously)
Upload resources.
|
okhttp3.Call |
RestApi.uploadResourcesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadResources
|
ApiResponse<ResourceMsg> |
RestApi.uploadResourcesWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload resources
Upload resources.
|
Copyright © 2023. All rights reserved.