public class RestApi extends Object
Modifier and Type | Method and Description |
---|---|
ResponseInfo |
alertResourceOrGroupOwner(String projectId,
UpdateResourceOwner body,
String xAuthToken)
Modify owner of resource
Modify owner of resource.
|
okhttp3.Call |
alertResourceOrGroupOwnerAsync(String projectId,
UpdateResourceOwner body,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Modify owner of resource (asynchronously)
Modify owner of resource.
|
okhttp3.Call |
alertResourceOrGroupOwnerCall(String projectId,
UpdateResourceOwner body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for alertResourceOrGroupOwner
|
ApiResponse<ResponseInfo> |
alertResourceOrGroupOwnerWithHttpInfo(String projectId,
UpdateResourceOwner body,
String xAuthToken)
Modify owner of resource
Modify owner of resource.
|
GlobalResponse |
authorizeBucket(String projectId,
ObsBuckets obsBuckets,
String xAuthToken)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等
|
okhttp3.Call |
authorizeBucketAsync(String projectId,
ObsBuckets obsBuckets,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等 (asynchronously)
|
okhttp3.Call |
authorizeBucketCall(String projectId,
ObsBuckets obsBuckets,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for authorizeBucket
|
ApiResponse<GlobalResponse> |
authorizeBucketWithHttpInfo(String projectId,
ObsBuckets obsBuckets,
String xAuthToken)
用户主动授权起OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等
|
ResponseInfo |
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 |
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 |
cancelJob_0Call(String projectId,
String queueName,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for cancelJob_0
|
ApiResponse<ResponseInfo> |
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 |
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 |
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 |
cancelJobCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for cancelJob
|
ApiResponse<ResponseInfo> |
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 |
checkSQL(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Check sql
Check the SQL grammar.
|
okhttp3.Call |
checkSQLAsync(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Check sql (asynchronously)
Check the SQL grammar.
|
okhttp3.Call |
checkSQLCall(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for checkSQL
|
ApiResponse<ResponseJobInfo> |
checkSQLWithHttpInfo(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Check sql
Check the SQL grammar.
|
UploadCommitJobResult |
commitUploadJob(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken)
Commit direct upload job
Commit direct upload job for upload data to DLI.
|
okhttp3.Call |
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 |
commitUploadJobCall(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for commitUploadJob
|
ApiResponse<UploadCommitJobResult> |
commitUploadJobWithHttpInfo(String projectId,
UploadCommitJobRequest uploadCommitJobRequest,
String xAuthToken)
Commit direct upload job
Commit direct upload job for upload data to DLI.
|
SessionInfo |
createBatch(String projectId,
Object body,
String xAuthToken,
String USER_ID)
Create batch
Create batch.
|
okhttp3.Call |
createBatchAsync(String projectId,
Object body,
String xAuthToken,
String USER_ID,
ApiCallback<SessionInfo> callback)
Create batch (asynchronously)
Create batch.
|
okhttp3.Call |
createBatchCall(String projectId,
Object body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createBatch
|
ApiResponse<SessionInfo> |
createBatchWithHttpInfo(String projectId,
Object body,
String xAuthToken,
String USER_ID)
Create batch
Create batch.
|
EmptyResponse |
createCluster(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID)
Create cluster
Create cluster.
|
okhttp3.Call |
createClusterAsync(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID,
ApiCallback<EmptyResponse> callback)
Create cluster (asynchronously)
Create cluster.
|
okhttp3.Call |
createClusterCall(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createCluster
|
ApiResponse<EmptyResponse> |
createClusterWithHttpInfo(String projectId,
String xAuthToken,
CreateClusterRequest createClusterRequest,
String USER_ID)
Create cluster
Create cluster.
|
ResponseInfo |
createDatabase(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken)
Create database
create a database
|
okhttp3.Call |
createDatabaseAsync(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Create database (asynchronously)
create a database
|
okhttp3.Call |
createDatabaseCall(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createDatabase
|
ApiResponse<ResponseInfo> |
createDatabaseWithHttpInfo(String projectId,
DatabaseInfo databaseInfo,
String xAuthToken)
Create database
create a database
|
DownloadCreateJobResult |
createDownloadJob(String projectId,
EmptyBody emptyBody,
String xAuthToken)
Create direct download job
Create direct download job for download data from DLI.
|
okhttp3.Call |
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 |
createDownloadJobCall(String projectId,
EmptyBody emptyBody,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createDownloadJob
|
ApiResponse<DownloadCreateJobResult> |
createDownloadJobWithHttpInfo(String projectId,
EmptyBody emptyBody,
String xAuthToken)
Create direct download job
Create direct download job for download data from DLI.
|
FlinkJobTemplateCreateResponse |
createFlinkJobTemplate(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken)
创建作业模板
Create job template on Data lake insight
|
okhttp3.Call |
createFlinkJobTemplateAsync(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken,
ApiCallback<FlinkJobTemplateCreateResponse> callback)
创建作业模板 (asynchronously)
Create job template on Data lake insight
|
okhttp3.Call |
createFlinkJobTemplateCall(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createFlinkJobTemplate
|
ApiResponse<FlinkJobTemplateCreateResponse> |
createFlinkJobTemplateWithHttpInfo(String projectId,
CreateFlinkJobTemplateRequest body,
String xAuthToken)
创建作业模板
Create job template on Data lake insight
|
ObsSelectJobResult |
createObsSelectJob(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken)
Create Obs select job
Create Obs select job to DLI.
|
okhttp3.Call |
createObsSelectJobAsync(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken,
ApiCallback<ObsSelectJobResult> callback)
Create Obs select job (asynchronously)
Create Obs select job to DLI.
|
okhttp3.Call |
createObsSelectJobCall(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createObsSelectJob
|
ApiResponse<ObsSelectJobResult> |
createObsSelectJobWithHttpInfo(String projectId,
ObsSelectJobRequest obsSelectJobRequest,
String xAuthToken)
Create Obs select job
Create Obs select job to DLI.
|
ResponseQueueInfo |
createQueue(String projectId,
QueueInfo queueInfo,
String xAuthToken)
Create queue
Create a queue that will bind user-specified computing resources.
|
okhttp3.Call |
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 |
createQueueCall(String projectId,
QueueInfo queueInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createQueue
|
ApiResponse<ResponseQueueInfo> |
createQueueWithHttpInfo(String projectId,
QueueInfo queueInfo,
String xAuthToken)
Create queue
Create a queue that will bind user-specified computing resources.
|
ResponseInfo |
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 |
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 |
createTableCall(String projectId,
String databaseName,
TableInfo tableInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createTable
|
ApiResponse<ResponseInfo> |
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 |
createTsdb(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken)
创建时序数据库配置信息
|
okhttp3.Call |
createTsdbAsync(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken,
ApiCallback<CreateTsdbResp> callback)
创建时序数据库配置信息 (asynchronously)
|
okhttp3.Call |
createTsdbCall(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createTsdb
|
ApiResponse<CreateTsdbResp> |
createTsdbWithHttpInfo(CreateTsdbReq createTsdbReq,
String projectId,
String xAuthToken)
创建时序数据库配置信息
|
UploadCreateJobResult |
createUploadJob(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken)
Create direct upload job
Create direct upload job for upload data to DLI.
|
okhttp3.Call |
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 |
createUploadJobCall(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for createUploadJob
|
ApiResponse<UploadCreateJobResult> |
createUploadJobWithHttpInfo(String projectId,
UploadCreateJobRequest uploadCreateJobRequest,
String xAuthToken)
Create direct upload job
Create direct upload job for upload data to DLI.
|
ResponseInfo |
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 |
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 |
dataAuthorizeCall(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for dataAuthorize
|
ApiResponse<ResponseInfo> |
dataAuthorizeWithHttpInfo(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken)
List queue users
Privilege data permissions to the database or data table to other specified users.
|
MessageInfo |
delBatch(String projectId,
String batchId,
String xAuthToken)
Delete specified batch
Delete specified batch.
|
okhttp3.Call |
delBatchAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<MessageInfo> callback)
Delete specified batch (asynchronously)
Delete specified batch.
|
okhttp3.Call |
delBatchCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for delBatch
|
ApiResponse<MessageInfo> |
delBatchWithHttpInfo(String projectId,
String batchId,
String xAuthToken)
Delete specified batch
Delete specified batch.
|
EmptyResponse |
deleteCluster(String projectId,
String clusterName,
String xAuthToken)
Delete cluster
Delete cluster.
|
okhttp3.Call |
deleteClusterAsync(String projectId,
String clusterName,
String xAuthToken,
ApiCallback<EmptyResponse> callback)
Delete cluster (asynchronously)
Delete cluster.
|
okhttp3.Call |
deleteClusterCall(String projectId,
String clusterName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteCluster
|
ApiResponse<EmptyResponse> |
deleteClusterWithHttpInfo(String projectId,
String clusterName,
String xAuthToken)
Delete cluster
Delete cluster.
|
ResponseInfo |
deleteDatabase(String projectId,
String databaseName,
String xAuthToken)
Delete database
Delete database by database name.
|
okhttp3.Call |
deleteDatabaseAsync(String projectId,
String databaseName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete database (asynchronously)
Delete database by database name.
|
okhttp3.Call |
deleteDatabaseCall(String projectId,
String databaseName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteDatabase
|
ApiResponse<ResponseInfo> |
deleteDatabaseWithHttpInfo(String projectId,
String databaseName,
String xAuthToken)
Delete database
Delete database by database name.
|
List<GlobalBatchResponse> |
deleteFlinkJob(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken)
批量删除作业
|
okhttp3.Call |
deleteFlinkJobAsync(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
批量删除作业 (asynchronously)
|
okhttp3.Call |
deleteFlinkJobCall(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteFlinkJob
|
FlinkJobTemplateDeleteResponse |
deleteFlinkJobTemplate(String projectId,
Long templateId,
String xAuthToken)
删除作业模板
当前模板被引用也允许删除模板
|
okhttp3.Call |
deleteFlinkJobTemplateAsync(String projectId,
Long templateId,
String xAuthToken,
ApiCallback<FlinkJobTemplateDeleteResponse> callback)
删除作业模板 (asynchronously)
当前模板被引用也允许删除模板
|
okhttp3.Call |
deleteFlinkJobTemplateCall(String projectId,
Long templateId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteFlinkJobTemplate
|
ApiResponse<FlinkJobTemplateDeleteResponse> |
deleteFlinkJobTemplateWithHttpInfo(String projectId,
Long templateId,
String xAuthToken)
删除作业模板
当前模板被引用也允许删除模板
|
ApiResponse<List<GlobalBatchResponse>> |
deleteFlinkJobWithHttpInfo(String projectId,
DeleteJobInBatchRequest deleteJobInBatchRequest,
String xAuthToken)
批量删除作业
|
GlobalResponse |
deleteJob(String projectId,
Long jobId,
String xAuthToken)
删除作业
删除任何状态的作业
|
okhttp3.Call |
deleteJobAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
删除作业 (asynchronously)
删除任何状态的作业
|
okhttp3.Call |
deleteJobCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteJob
|
ApiResponse<GlobalResponse> |
deleteJobWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
删除作业
删除任何状态的作业
|
ResponseInfo |
deleteQueue(String projectId,
String queueName,
String xAuthToken)
Delete queue
Delete the specified queue.
|
okhttp3.Call |
deleteQueueAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete queue (asynchronously)
Delete the specified queue.
|
okhttp3.Call |
deleteQueueCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteQueue
|
ApiResponse<ResponseInfo> |
deleteQueueWithHttpInfo(String projectId,
String queueName,
String xAuthToken)
Delete queue
Delete the specified queue.
|
EmptyResponse |
deleteResource(String projectId,
String resourceName,
String group,
String xAuthToken)
Delete specified resource
Delete specified resource.
|
okhttp3.Call |
deleteResourceAsync(String projectId,
String resourceName,
String group,
String xAuthToken,
ApiCallback<EmptyResponse> callback)
Delete specified resource (asynchronously)
Delete specified resource.
|
okhttp3.Call |
deleteResourceCall(String projectId,
String resourceName,
String group,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteResource
|
ApiResponse<EmptyResponse> |
deleteResourceWithHttpInfo(String projectId,
String resourceName,
String group,
String xAuthToken)
Delete specified resource
Delete specified resource.
|
ResponseInfo |
deleteTable(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Delete table
Delete the specified table.
|
okhttp3.Call |
deleteTableAsync(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ApiCallback<ResponseInfo> callback)
Delete table (asynchronously)
Delete the specified table.
|
okhttp3.Call |
deleteTableCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteTable
|
ApiResponse<ResponseInfo> |
deleteTableWithHttpInfo(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Delete table
Delete the specified table.
|
GlobalResponse |
deleteTsdb(String projectId,
String tsdbId,
String xAuthToken)
删除时序数据库配置信息
删除时序数据库配置信息
|
okhttp3.Call |
deleteTsdbAsync(String projectId,
String tsdbId,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
删除时序数据库配置信息 (asynchronously)
删除时序数据库配置信息
|
okhttp3.Call |
deleteTsdbCall(String projectId,
String tsdbId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for deleteTsdb
|
ApiResponse<GlobalResponse> |
deleteTsdbWithHttpInfo(String projectId,
String tsdbId,
String xAuthToken)
删除时序数据库配置信息
删除时序数据库配置信息
|
ColumnResult |
describeTable(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Describe Table
Describes the metadata information for the specified table.
|
okhttp3.Call |
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 |
describeTableCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for describeTable
|
ApiResponse<ColumnResult> |
describeTableWithHttpInfo(String projectId,
String databaseName,
String tableName,
String xAuthToken)
Describe Table
Describes the metadata information for the specified table.
|
ResponseJobInfo |
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 |
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 |
execute_0Call(String projectId,
String queueName,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for execute_0
|
ApiResponse<ResponseJobInfo> |
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 |
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 |
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 |
executeCall(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for execute
|
ApiResponse<ResponseJobInfo> |
executeWithHttpInfo(String projectId,
SQLJobRequest sqLJobInfo,
String xAuthToken)
Submit job
This API is used to submit jobs to the cluster by executing SQL statements.
|
ResponseJobInfo |
exportData(String projectId,
ExportJobRequest exportInfo,
String xAuthToken)
Export data
Export the data to a file.
|
okhttp3.Call |
exportDataAsync(String projectId,
ExportJobRequest exportInfo,
String xAuthToken,
ApiCallback<ResponseJobInfo> callback)
Export data (asynchronously)
Export the data to a file.
|
okhttp3.Call |
exportDataCall(String projectId,
ExportJobRequest exportInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for exportData
|
ApiResponse<ResponseJobInfo> |
exportDataWithHttpInfo(String projectId,
ExportJobRequest exportInfo,
String xAuthToken)
Export data
Export the data to a file.
|
ApiClient |
getApiClient() |
SessionInfo |
getBatchInfo(String projectId,
String batchId,
String xAuthToken)
List specified batch
List specified batch.
|
okhttp3.Call |
getBatchInfoAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<SessionInfo> callback)
List specified batch (asynchronously)
List specified batch.
|
okhttp3.Call |
getBatchInfoCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchInfo
|
ApiResponse<SessionInfo> |
getBatchInfoWithHttpInfo(String projectId,
String batchId,
String xAuthToken)
List specified batch
List specified batch.
|
SessionInfos |
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 |
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 |
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> |
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 |
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 |
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 |
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> |
getBatchLogWithHttpInfo(String projectId,
String batchId,
String xAuthToken,
Integer from,
Integer size,
String type,
Integer index)
Get specified batch log
Get specified batch log.
|
SessionState |
getBatchState(String projectId,
String batchId,
String xAuthToken)
Get specified session state
Get specified session state.
|
okhttp3.Call |
getBatchStateAsync(String projectId,
String batchId,
String xAuthToken,
ApiCallback<SessionState> callback)
Get specified session state (asynchronously)
Get specified session state.
|
okhttp3.Call |
getBatchStateCall(String projectId,
String batchId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getBatchState
|
ApiResponse<SessionState> |
getBatchStateWithHttpInfo(String projectId,
String batchId,
String xAuthToken)
Get specified session state
Get specified session state.
|
ClusterInfo |
getCluster(String projectId,
String clusterName,
String xAuthToken)
List specified cluster
List specified cluster.
|
okhttp3.Call |
getClusterAsync(String projectId,
String clusterName,
String xAuthToken,
ApiCallback<ClusterInfo> callback)
List specified cluster (asynchronously)
List specified cluster.
|
okhttp3.Call |
getClusterCall(String projectId,
String clusterName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getCluster
|
ApiResponse<ClusterInfo> |
getClusterWithHttpInfo(String projectId,
String clusterName,
String xAuthToken)
List specified cluster
List specified cluster.
|
FlinkJobApigSinksResponse |
getFlinkApigSinks(String projectId,
Long jobId,
String xAuthToken)
查询作业apig网关服务访问地址
The apig sinks is json format.
|
okhttp3.Call |
getFlinkApigSinksAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<FlinkJobApigSinksResponse> callback)
查询作业apig网关服务访问地址 (asynchronously)
The apig sinks is json format.
|
okhttp3.Call |
getFlinkApigSinksCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkApigSinks
|
ApiResponse<FlinkJobApigSinksResponse> |
getFlinkApigSinksWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
查询作业apig网关服务访问地址
The apig sinks is json format.
|
GetFlinkJobDetailResponse |
getFlinkJobDetail(String projectId,
Long jobId,
String xAuthToken)
查询作业详情
Get job detail information.
|
okhttp3.Call |
getFlinkJobDetailAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<GetFlinkJobDetailResponse> callback)
查询作业详情 (asynchronously)
Get job detail information.
|
okhttp3.Call |
getFlinkJobDetailCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobDetail
|
ApiResponse<GetFlinkJobDetailResponse> |
getFlinkJobDetailWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
查询作业详情
Get job detail information.
|
FlinkJobExecutePlanResponse |
getFlinkJobExecuteGraph(String projectId,
Long jobId,
String xAuthToken)
查询作业执行计划图
The execution graph is json format.
|
okhttp3.Call |
getFlinkJobExecuteGraphAsync(String projectId,
Long jobId,
String xAuthToken,
ApiCallback<FlinkJobExecutePlanResponse> callback)
查询作业执行计划图 (asynchronously)
The execution graph is json format.
|
okhttp3.Call |
getFlinkJobExecuteGraphCall(String projectId,
Long jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobExecuteGraph
|
ApiResponse<FlinkJobExecutePlanResponse> |
getFlinkJobExecuteGraphWithHttpInfo(String projectId,
Long jobId,
String xAuthToken)
查询作业执行计划图
The execution graph is json format.
|
QueryFlinkJobListResponse |
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 |
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 |
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 |
getFlinkJobsMetrics(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken)
查询作业监控信息
查询作业监控信息, 支持同时查询多个作业监控信息
|
okhttp3.Call |
getFlinkJobsMetricsAsync(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken,
ApiCallback<QueryFlinkJobMetricsResponse> callback)
查询作业监控信息 (asynchronously)
查询作业监控信息, 支持同时查询多个作业监控信息
|
okhttp3.Call |
getFlinkJobsMetricsCall(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobsMetrics
|
ApiResponse<QueryFlinkJobMetricsResponse> |
getFlinkJobsMetricsWithHttpInfo(String projectId,
GetFlinkJobsMetricsBody getFlinkJobsMetricsBody,
String xAuthToken)
查询作业监控信息
查询作业监控信息, 支持同时查询多个作业监控信息
|
ApiResponse<QueryFlinkJobListResponse> |
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 |
getFlinkJobTemplates(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order)
查询作业模板列表
|
okhttp3.Call |
getFlinkJobTemplatesAsync(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order,
ApiCallback<FlinkJobTemplateListResponse> callback)
查询作业模板列表 (asynchronously)
|
okhttp3.Call |
getFlinkJobTemplatesCall(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getFlinkJobTemplates
|
ApiResponse<FlinkJobTemplateListResponse> |
getFlinkJobTemplatesWithHttpInfo(String projectId,
String xAuthToken,
Long offset,
Integer limit,
String order)
查询作业模板列表
|
DetailResult |
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 |
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 |
getImportExportJobInfoCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getImportExportJobInfo
|
ApiResponse<DetailResult> |
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 |
getJobProgress(String projectId,
String jobId,
String xAuthToken)
Get job progress
Get job progress
|
okhttp3.Call |
getJobProgressAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<JobProgressResult> callback)
Get job progress (asynchronously)
Get job progress
|
okhttp3.Call |
getJobProgressCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobProgress
|
ApiResponse<JobProgressResult> |
getJobProgressWithHttpInfo(String projectId,
String jobId,
String xAuthToken)
Get job progress
Get job progress
|
JobResult |
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 |
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 |
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> |
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 |
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 |
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 |
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> |
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 |
getJobStatus(String projectId,
String jobId,
String xAuthToken)
Get job status
Get job status after job submission.
|
okhttp3.Call |
getJobStatusAsync(String projectId,
String jobId,
String xAuthToken,
ApiCallback<StatusResult> callback)
Get job status (asynchronously)
Get job status after job submission.
|
okhttp3.Call |
getJobStatusCall(String projectId,
String jobId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getJobStatus
|
ApiResponse<StatusResult> |
getJobStatusWithHttpInfo(String projectId,
String jobId,
String xAuthToken)
Get job status
Get job status after job submission.
|
PkgResourceInfo |
getResourceInfo(String projectId,
String resourceName,
String group,
String xAuthToken)
List specified resource
List specified resource.
|
okhttp3.Call |
getResourceInfoAsync(String projectId,
String resourceName,
String group,
String xAuthToken,
ApiCallback<PkgResourceInfo> callback)
List specified resource (asynchronously)
List specified resource.
|
okhttp3.Call |
getResourceInfoCall(String projectId,
String resourceName,
String group,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getResourceInfo
|
ApiResponse<PkgResourceInfo> |
getResourceInfoWithHttpInfo(String projectId,
String resourceName,
String group,
String xAuthToken)
List specified resource
List specified resource.
|
QueueInfo |
getSpecifiedQueue(String projectId,
String queueName,
String xAuthToken)
Get queue
Get the specified queue.
|
okhttp3.Call |
getSpecifiedQueueAsync(String projectId,
String queueName,
String xAuthToken,
ApiCallback<QueueInfo> callback)
Get queue (asynchronously)
Get the specified queue.
|
okhttp3.Call |
getSpecifiedQueueCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getSpecifiedQueue
|
ApiResponse<QueueInfo> |
getSpecifiedQueueWithHttpInfo(String projectId,
String queueName,
String xAuthToken)
Get queue
Get the specified queue.
|
GetTsdbByIdResp |
getTsdbById(String projectId,
Long tsdbId,
String xAuthToken)
查询时序数据库配置信息详情
根据时序数据库ID,查询时序数据库详情
|
okhttp3.Call |
getTsdbByIdAsync(String projectId,
Long tsdbId,
String xAuthToken,
ApiCallback<GetTsdbByIdResp> callback)
查询时序数据库配置信息详情 (asynchronously)
根据时序数据库ID,查询时序数据库详情
|
okhttp3.Call |
getTsdbByIdCall(String projectId,
Long tsdbId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getTsdbById
|
ApiResponse<GetTsdbByIdResp> |
getTsdbByIdWithHttpInfo(String projectId,
Long tsdbId,
String xAuthToken)
查询时序数据库配置信息详情
根据时序数据库ID,查询时序数据库详情
|
GetTsdbListResp |
getTsdbList(String projectId,
Integer offset,
Integer limit,
String xAuthToken)
查询时序数据库配置信息列表
|
okhttp3.Call |
getTsdbListAsync(String projectId,
Integer offset,
Integer limit,
String xAuthToken,
ApiCallback<GetTsdbListResp> callback)
查询时序数据库配置信息列表 (asynchronously)
|
okhttp3.Call |
getTsdbListCall(String projectId,
Integer offset,
Integer limit,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for getTsdbList
|
ApiResponse<GetTsdbListResp> |
getTsdbListWithHttpInfo(String projectId,
Integer offset,
Integer limit,
String xAuthToken)
查询时序数据库配置信息列表
|
ResponseJobInfo |
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 |
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 |
importDataCall(String projectId,
ImportJobRequest importExportInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for importData
|
ApiResponse<ResponseJobInfo> |
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 |
listAllDatabases(String projectId,
String xAuthToken)
List all databases
List all databases info,include owner and table_number.
|
okhttp3.Call |
listAllDatabasesAsync(String projectId,
String xAuthToken,
ApiCallback<DatabaseResult> callback)
List all databases (asynchronously)
List all databases info,include owner and table_number.
|
okhttp3.Call |
listAllDatabasesCall(String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllDatabases
|
ApiResponse<DatabaseResult> |
listAllDatabasesWithHttpInfo(String projectId,
String xAuthToken)
List all databases
List all databases info,include owner and table_number.
|
JobListResult |
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 |
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 |
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> |
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 |
listAllQueues(String projectId,
String xAuthToken,
String queueType)
List all queues
List all the queues under the project.
|
okhttp3.Call |
listAllQueuesAsync(String projectId,
String xAuthToken,
String queueType,
ApiCallback<QueueResult> callback)
List all queues (asynchronously)
List all the queues under the project.
|
okhttp3.Call |
listAllQueuesCall(String projectId,
String xAuthToken,
String queueType,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listAllQueues
|
ApiResponse<QueueResult> |
listAllQueuesWithHttpInfo(String projectId,
String xAuthToken,
String queueType)
List all queues
List all the queues under the project.
|
TableListResult |
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 |
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 |
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> |
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 |
listCluster(String projectId,
String xAuthToken)
List all clusters
List all clusters.
|
okhttp3.Call |
listClusterAsync(String projectId,
String xAuthToken,
ApiCallback<ClusterInfos> callback)
List all clusters (asynchronously)
List all clusters.
|
okhttp3.Call |
listClusterCall(String projectId,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listCluster
|
ApiResponse<ClusterInfos> |
listClusterWithHttpInfo(String projectId,
String xAuthToken)
List all clusters
List all clusters.
|
PrivilegeResult |
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 |
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 |
listDatabaseUsersCall(String projectId,
String databaseName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listDatabaseUsers
|
ApiResponse<PrivilegeResult> |
listDatabaseUsersWithHttpInfo(String projectId,
String databaseName,
String xAuthToken)
List Database Users
View the current database has permission to use or access all user names.
|
PrivilegeResult |
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 |
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 |
listQueueUsersCall(String projectId,
String queueName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listQueueUsers
|
ApiResponse<PrivilegeResult> |
listQueueUsersWithHttpInfo(String projectId,
String queueName,
String xAuthToken)
List queue users
Queries all the user names of the specified queue that can be used.
|
ResourceInfos |
listResources(String projectId,
String xAuthToken,
String kind)
List all resources
List all resources.
|
okhttp3.Call |
listResourcesAsync(String projectId,
String xAuthToken,
String kind,
ApiCallback<ResourceInfos> callback)
List all resources (asynchronously)
List all resources.
|
okhttp3.Call |
listResourcesCall(String projectId,
String xAuthToken,
String kind,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listResources
|
ApiResponse<ResourceInfos> |
listResourcesWithHttpInfo(String projectId,
String xAuthToken,
String kind)
List all resources
List all resources.
|
JobListResult |
listSqlJobs(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags)
List all sql jobs
List all sql jobs
|
okhttp3.Call |
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 |
listSqlJobsCall(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listSqlJobs
|
ApiResponse<JobListResult> |
listSqlJobsWithHttpInfo(String projectId,
String xAuthToken,
Integer pageSize,
Integer currentPage,
String tags)
List all sql jobs
List all sql jobs
|
PrivilegeResult |
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 |
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 |
listTableUserPrivilegesCall(String projectId,
String databaseName,
String tableName,
String userName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listTableUserPrivileges
|
ApiResponse<PrivilegeResult> |
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 |
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 |
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 |
listTableUsersCall(String projectId,
String databaseName,
String tableName,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for listTableUsers
|
ApiResponse<PrivilegeResult> |
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 |
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 |
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 |
previewJobResultCall(String projectId,
String jobId,
String xAuthToken,
String queueName,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for previewJobResult
|
ApiResponse<JobResult> |
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 |
queueAction(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken)
队列操作
|
okhttp3.Call |
queueActionAsync(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken,
ApiCallback<QueueActionResponse> callback)
队列操作 (asynchronously)
|
okhttp3.Call |
queueActionCall(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for queueAction
|
ApiResponse<QueueActionResponse> |
queueActionWithHttpInfo(String projectId,
String queueName,
QueueActionRequest body,
String xAuthToken)
队列操作
|
List<GlobalBatchResponse> |
runFlinkJob(String projectId,
RunFlinkJobRequest body,
String xAuthToken)
运行作业
触发运行作业
|
okhttp3.Call |
runFlinkJobAsync(String projectId,
RunFlinkJobRequest body,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
运行作业 (asynchronously)
触发运行作业
|
okhttp3.Call |
runFlinkJobCall(String projectId,
RunFlinkJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for runFlinkJob
|
ApiResponse<List<GlobalBatchResponse>> |
runFlinkJobWithHttpInfo(String projectId,
RunFlinkJobRequest body,
String xAuthToken)
运行作业
触发运行作业
|
void |
setApiClient(ApiClient apiClient) |
ResponseInfo |
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 |
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 |
shareQueueCall(String projectId,
PrivilegeInfo privilegeInfo,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for shareQueue
|
ApiResponse<ResponseInfo> |
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 |
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 |
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 |
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> |
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> |
stopFlinkJob(String projectId,
StopFlinkJobRequest body,
String xAuthToken)
停止作业
|
okhttp3.Call |
stopFlinkJobAsync(String projectId,
StopFlinkJobRequest body,
String xAuthToken,
ApiCallback<List<GlobalBatchResponse>> callback)
停止作业 (asynchronously)
|
okhttp3.Call |
stopFlinkJobCall(String projectId,
StopFlinkJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for stopFlinkJob
|
ApiResponse<List<GlobalBatchResponse>> |
stopFlinkJobWithHttpInfo(String projectId,
StopFlinkJobRequest body,
String xAuthToken)
停止作业
|
ResponseJobInfo |
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 |
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 |
storeJobResultCall(String projectId,
String jobId,
String xAuthToken,
ExportCommonInfo exportCommonInfo,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for storeJobResult
|
ApiResponse<ResponseJobInfo> |
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 |
submitFlinkJarJob(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
submitFlinkJarJobAsync(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
创建一个用户自定义Flink作业 (asynchronously)
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
submitFlinkJarJobCall(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkJarJob
|
ApiResponse<JobStatusResponse> |
submitFlinkJarJobWithHttpInfo(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
JobStatusResponse |
submitFlinkSqlJob(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken)
提交流式SQL作业到DLI服务
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
okhttp3.Call |
submitFlinkSqlJobAsync(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
提交流式SQL作业到DLI服务 (asynchronously)
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
okhttp3.Call |
submitFlinkSqlJobCall(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkSqlJob
|
ApiResponse<JobStatusResponse> |
submitFlinkSqlJobWithHttpInfo(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken)
提交流式SQL作业到DLI服务
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
JobUpdateResponse |
updateFlinkJarJob(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken)
更新用户自定义Flink作业
目前仅支持Jar格式, 运行在独享集群中
|
okhttp3.Call |
updateFlinkJarJobAsync(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新用户自定义Flink作业 (asynchronously)
目前仅支持Jar格式, 运行在独享集群中
|
okhttp3.Call |
updateFlinkJarJobCall(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkJarJob
|
ApiResponse<JobUpdateResponse> |
updateFlinkJarJobWithHttpInfo(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken)
更新用户自定义Flink作业
目前仅支持Jar格式, 运行在独享集群中
|
GlobalResponse |
updateFlinkJobTemplate(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken)
更新作业模板
Update job template on Data lake insight
|
okhttp3.Call |
updateFlinkJobTemplateAsync(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
更新作业模板 (asynchronously)
Update job template on Data lake insight
|
okhttp3.Call |
updateFlinkJobTemplateCall(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkJobTemplate
|
ApiResponse<GlobalResponse> |
updateFlinkJobTemplateWithHttpInfo(String projectId,
Long templateId,
UpdateFlinkJobTemplateRequest body,
String xAuthToken)
更新作业模板
Update job template on Data lake insight
|
JobUpdateResponse |
updateFlinkSqlJob(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken)
更新流式SQL作业
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
okhttp3.Call |
updateFlinkSqlJobAsync(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新流式SQL作业 (asynchronously)
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
okhttp3.Call |
updateFlinkSqlJobCall(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateFlinkSqlJob
|
ApiResponse<JobUpdateResponse> |
updateFlinkSqlJobWithHttpInfo(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken)
更新流式SQL作业
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
GlobalResponse |
updateTsdb(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken)
修改时序数据库配置信息
修改时序数据库配置信息
|
okhttp3.Call |
updateTsdbAsync(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken,
ApiCallback<GlobalResponse> callback)
修改时序数据库配置信息 (asynchronously)
修改时序数据库配置信息
|
okhttp3.Call |
updateTsdbCall(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for updateTsdb
|
ApiResponse<GlobalResponse> |
updateTsdbWithHttpInfo(String projectId,
String tsdbId,
UpdateTsdbReq updateTsdbReq,
String xAuthToken)
修改时序数据库配置信息
修改时序数据库配置信息
|
ResourceMsg |
uploadFiles(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload files
Upload files.
|
okhttp3.Call |
uploadFilesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload files (asynchronously)
Upload files.
|
okhttp3.Call |
uploadFilesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadFiles
|
ApiResponse<ResourceMsg> |
uploadFilesWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload files
Upload files.
|
ResourceMsg |
uploadJars(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload jars
Upload jars.
|
okhttp3.Call |
uploadJarsAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload jars (asynchronously)
Upload jars.
|
okhttp3.Call |
uploadJarsCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadJars
|
ApiResponse<ResourceMsg> |
uploadJarsWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload jars
Upload jars.
|
ResourceMsg |
uploadPyFiles(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload pyfiles
Upload pyfiles.
|
okhttp3.Call |
uploadPyFilesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload pyfiles (asynchronously)
Upload pyfiles.
|
okhttp3.Call |
uploadPyFilesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadPyFiles
|
ApiResponse<ResourceMsg> |
uploadPyFilesWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload pyfiles
Upload pyfiles.
|
ResourceMsg |
uploadResources(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload resources
Upload resources.
|
okhttp3.Call |
uploadResourcesAsync(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ApiCallback<ResourceMsg> callback)
Upload resources (asynchronously)
Upload resources.
|
okhttp3.Call |
uploadResourcesCall(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for uploadResources
|
ApiResponse<ResourceMsg> |
uploadResourcesWithHttpInfo(String projectId,
PkgResourceRequest body,
String xAuthToken,
String USER_ID)
Upload resources
Upload resources.
|
public RestApi()
public RestApi(ApiClient apiClient)
public ApiClient getApiClient()
public void setApiClient(ApiClient apiClient)
public okhttp3.Call alertResourceOrGroupOwnerCall(String projectId, UpdateResourceOwner body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo alertResourceOrGroupOwner(String projectId, UpdateResourceOwner body, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> alertResourceOrGroupOwnerWithHttpInfo(String projectId, UpdateResourceOwner body, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call alertResourceOrGroupOwnerAsync(String projectId, UpdateResourceOwner body, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call authorizeBucketCall(String projectId, ObsBuckets obsBuckets, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)obsBuckets
- 授权一个或多个OBS bucket权限给Data lake insight, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GlobalResponse authorizeBucket(String projectId, ObsBuckets obsBuckets, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)obsBuckets
- 授权一个或多个OBS bucket权限给Data lake insight, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GlobalResponse> authorizeBucketWithHttpInfo(String projectId, ObsBuckets obsBuckets, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)obsBuckets
- 授权一个或多个OBS bucket权限给Data lake insight, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call authorizeBucketAsync(String projectId, ObsBuckets obsBuckets, String xAuthToken, ApiCallback<GlobalResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)obsBuckets
- 授权一个或多个OBS bucket权限给Data lake insight, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call cancelJobCall(String projectId, String jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo cancelJob(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> cancelJobWithHttpInfo(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call cancelJobAsync(String projectId, String jobId, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call cancelJob_0Call(String projectId, String queueName, String jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo cancelJob_0(String projectId, String queueName, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> cancelJob_0WithHttpInfo(String projectId, String queueName, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call cancelJob_0Async(String projectId, String queueName, String jobId, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call checkSQLCall(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseJobInfo checkSQL(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseJobInfo> checkSQLWithHttpInfo(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call checkSQLAsync(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken, ApiCallback<ResponseJobInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call commitUploadJobCall(String projectId, UploadCommitJobRequest uploadCommitJobRequest, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCommitJobRequest
- Request parameters for commit direct upload job (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic UploadCommitJobResult commitUploadJob(String projectId, UploadCommitJobRequest uploadCommitJobRequest, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCommitJobRequest
- Request parameters for commit direct upload job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<UploadCommitJobResult> commitUploadJobWithHttpInfo(String projectId, UploadCommitJobRequest uploadCommitJobRequest, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCommitJobRequest
- Request parameters for commit direct upload job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call commitUploadJobAsync(String projectId, UploadCommitJobRequest uploadCommitJobRequest, String xAuthToken, ApiCallback<UploadCommitJobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCommitJobRequest
- Request parameters for commit direct upload job (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createBatchCall(String projectId, Object body, String xAuthToken, String USER_ID, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic SessionInfo createBatch(String projectId, Object body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<SessionInfo> createBatchWithHttpInfo(String projectId, Object body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createBatchAsync(String projectId, Object body, String xAuthToken, String USER_ID, ApiCallback<SessionInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createClusterCall(String projectId, String xAuthToken, CreateClusterRequest createClusterRequest, String USER_ID, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (required)createClusterRequest
- (required)USER_ID
- Real user id (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic EmptyResponse createCluster(String projectId, String xAuthToken, CreateClusterRequest createClusterRequest, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (required)createClusterRequest
- (required)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<EmptyResponse> createClusterWithHttpInfo(String projectId, String xAuthToken, CreateClusterRequest createClusterRequest, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (required)createClusterRequest
- (required)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createClusterAsync(String projectId, String xAuthToken, CreateClusterRequest createClusterRequest, String USER_ID, ApiCallback<EmptyResponse> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (required)createClusterRequest
- (required)USER_ID
- Real user id (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createDatabaseCall(String projectId, DatabaseInfo databaseInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseInfo
- \"database_name\":\"dbName\", \"description\":\"this is the database description template.\" (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo createDatabase(String projectId, DatabaseInfo databaseInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseInfo
- \"database_name\":\"dbName\", \"description\":\"this is the database description template.\" (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> createDatabaseWithHttpInfo(String projectId, DatabaseInfo databaseInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseInfo
- \"database_name\":\"dbName\", \"description\":\"this is the database description template.\" (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createDatabaseAsync(String projectId, DatabaseInfo databaseInfo, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseInfo
- \"database_name\":\"dbName\", \"description\":\"this is the database description template.\" (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createDownloadJobCall(String projectId, EmptyBody emptyBody, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)emptyBody
- Request parameters for create direct download job (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic DownloadCreateJobResult createDownloadJob(String projectId, EmptyBody emptyBody, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)emptyBody
- Request parameters for create direct download job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<DownloadCreateJobResult> createDownloadJobWithHttpInfo(String projectId, EmptyBody emptyBody, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)emptyBody
- Request parameters for create direct download job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createDownloadJobAsync(String projectId, EmptyBody emptyBody, String xAuthToken, ApiCallback<DownloadCreateJobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)emptyBody
- Request parameters for create direct download job (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createFlinkJobTemplateCall(String projectId, CreateFlinkJobTemplateRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- Create job template request (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic FlinkJobTemplateCreateResponse createFlinkJobTemplate(String projectId, CreateFlinkJobTemplateRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- Create job template request (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<FlinkJobTemplateCreateResponse> createFlinkJobTemplateWithHttpInfo(String projectId, CreateFlinkJobTemplateRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- Create job template request (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createFlinkJobTemplateAsync(String projectId, CreateFlinkJobTemplateRequest body, String xAuthToken, ApiCallback<FlinkJobTemplateCreateResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- Create job template request (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createObsSelectJobCall(String projectId, ObsSelectJobRequest obsSelectJobRequest, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)obsSelectJobRequest
- Request parameters for create upload job (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ObsSelectJobResult createObsSelectJob(String projectId, ObsSelectJobRequest obsSelectJobRequest, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)obsSelectJobRequest
- Request parameters for create upload job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ObsSelectJobResult> createObsSelectJobWithHttpInfo(String projectId, ObsSelectJobRequest obsSelectJobRequest, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)obsSelectJobRequest
- Request parameters for create upload job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createObsSelectJobAsync(String projectId, ObsSelectJobRequest obsSelectJobRequest, String xAuthToken, ApiCallback<ObsSelectJobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)obsSelectJobRequest
- Request parameters for create upload job (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createQueueCall(String projectId, QueueInfo queueInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueInfo
- Request parameters (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseQueueInfo createQueue(String projectId, QueueInfo queueInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueInfo
- Request parameters (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseQueueInfo> createQueueWithHttpInfo(String projectId, QueueInfo queueInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueInfo
- Request parameters (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createQueueAsync(String projectId, QueueInfo queueInfo, String xAuthToken, ApiCallback<ResponseQueueInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueInfo
- Request parameters (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createTableCall(String projectId, String databaseName, TableInfo tableInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- New table where the database name. (required)tableInfo
- New table request parameters. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo createTable(String projectId, String databaseName, TableInfo tableInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- New table where the database name. (required)tableInfo
- New table request parameters. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> createTableWithHttpInfo(String projectId, String databaseName, TableInfo tableInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- New table where the database name. (required)tableInfo
- New table request parameters. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createTableAsync(String projectId, String databaseName, TableInfo tableInfo, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- New table where the database name. (required)tableInfo
- New table request parameters. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createTsdbCall(CreateTsdbReq createTsdbReq, String projectId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
createTsdbReq
- This is a auto create Body Object (required)projectId
- (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic CreateTsdbResp createTsdb(CreateTsdbReq createTsdbReq, String projectId, String xAuthToken) throws ApiException
createTsdbReq
- This is a auto create Body Object (required)projectId
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<CreateTsdbResp> createTsdbWithHttpInfo(CreateTsdbReq createTsdbReq, String projectId, String xAuthToken) throws ApiException
createTsdbReq
- This is a auto create Body Object (required)projectId
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createTsdbAsync(CreateTsdbReq createTsdbReq, String projectId, String xAuthToken, ApiCallback<CreateTsdbResp> callback) throws ApiException
createTsdbReq
- This is a auto create Body Object (required)projectId
- (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call createUploadJobCall(String projectId, UploadCreateJobRequest uploadCreateJobRequest, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCreateJobRequest
- Request parameters for create direct upload job (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic UploadCreateJobResult createUploadJob(String projectId, UploadCreateJobRequest uploadCreateJobRequest, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCreateJobRequest
- Request parameters for create direct upload job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<UploadCreateJobResult> createUploadJobWithHttpInfo(String projectId, UploadCreateJobRequest uploadCreateJobRequest, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCreateJobRequest
- Request parameters for create direct upload job (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call createUploadJobAsync(String projectId, UploadCreateJobRequest uploadCreateJobRequest, String xAuthToken, ApiCallback<UploadCreateJobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)uploadCreateJobRequest
- Request parameters for create direct upload job (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call dataAuthorizeCall(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo dataAuthorize(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> dataAuthorizeWithHttpInfo(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call dataAuthorizeAsync(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call delBatchCall(String projectId, String batchId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic MessageInfo delBatch(String projectId, String batchId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<MessageInfo> delBatchWithHttpInfo(String projectId, String batchId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call delBatchAsync(String projectId, String batchId, String xAuthToken, ApiCallback<MessageInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteClusterCall(String projectId, String clusterName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic EmptyResponse deleteCluster(String projectId, String clusterName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<EmptyResponse> deleteClusterWithHttpInfo(String projectId, String clusterName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteClusterAsync(String projectId, String clusterName, String xAuthToken, ApiCallback<EmptyResponse> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteDatabaseCall(String projectId, String databaseName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- Delete database by this name. (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo deleteDatabase(String projectId, String databaseName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- Delete database by this name. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> deleteDatabaseWithHttpInfo(String projectId, String databaseName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- Delete database by this name. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteDatabaseAsync(String projectId, String databaseName, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- Delete database by this name. (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteFlinkJobCall(String projectId, DeleteJobInBatchRequest deleteJobInBatchRequest, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)deleteJobInBatchRequest
- (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic List<GlobalBatchResponse> deleteFlinkJob(String projectId, DeleteJobInBatchRequest deleteJobInBatchRequest, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)deleteJobInBatchRequest
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<List<GlobalBatchResponse>> deleteFlinkJobWithHttpInfo(String projectId, DeleteJobInBatchRequest deleteJobInBatchRequest, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)deleteJobInBatchRequest
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteFlinkJobAsync(String projectId, DeleteJobInBatchRequest deleteJobInBatchRequest, String xAuthToken, ApiCallback<List<GlobalBatchResponse>> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)deleteJobInBatchRequest
- (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteFlinkJobTemplateCall(String projectId, Long templateId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic FlinkJobTemplateDeleteResponse deleteFlinkJobTemplate(String projectId, Long templateId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<FlinkJobTemplateDeleteResponse> deleteFlinkJobTemplateWithHttpInfo(String projectId, Long templateId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteFlinkJobTemplateAsync(String projectId, Long templateId, String xAuthToken, ApiCallback<FlinkJobTemplateDeleteResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteJobCall(String projectId, Long jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GlobalResponse deleteJob(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GlobalResponse> deleteJobWithHttpInfo(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteJobAsync(String projectId, Long jobId, String xAuthToken, ApiCallback<GlobalResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteQueueCall(String projectId, String queueName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo deleteQueue(String projectId, String queueName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> deleteQueueWithHttpInfo(String projectId, String queueName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteQueueAsync(String projectId, String queueName, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteResourceCall(String projectId, String resourceName, String group, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic EmptyResponse deleteResource(String projectId, String resourceName, String group, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<EmptyResponse> deleteResourceWithHttpInfo(String projectId, String resourceName, String group, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteResourceAsync(String projectId, String resourceName, String group, String xAuthToken, ApiCallback<EmptyResponse> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteTableCall(String projectId, String databaseName, String tableName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be deleted is located. (required)tableName
- The name of the table to be deleted. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo deleteTable(String projectId, String databaseName, String tableName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be deleted is located. (required)tableName
- The name of the table to be deleted. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> deleteTableWithHttpInfo(String projectId, String databaseName, String tableName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be deleted is located. (required)tableName
- The name of the table to be deleted. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteTableAsync(String projectId, String databaseName, String tableName, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be deleted is located. (required)tableName
- The name of the table to be deleted. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call deleteTsdbCall(String projectId, String tsdbId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- (required)tsdbId
- (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GlobalResponse deleteTsdb(String projectId, String tsdbId, String xAuthToken) throws ApiException
projectId
- (required)tsdbId
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GlobalResponse> deleteTsdbWithHttpInfo(String projectId, String tsdbId, String xAuthToken) throws ApiException
projectId
- (required)tsdbId
- (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call deleteTsdbAsync(String projectId, String tsdbId, String xAuthToken, ApiCallback<GlobalResponse> callback) throws ApiException
projectId
- (required)tsdbId
- (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call describeTableCall(String projectId, String databaseName, String tableName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ColumnResult describeTable(String projectId, String databaseName, String tableName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ColumnResult> describeTableWithHttpInfo(String projectId, String databaseName, String tableName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call describeTableAsync(String projectId, String databaseName, String tableName, String xAuthToken, ApiCallback<ColumnResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call executeCall(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseJobInfo execute(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseJobInfo> executeWithHttpInfo(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call executeAsync(String projectId, SQLJobRequest sqLJobInfo, String xAuthToken, ApiCallback<ResponseJobInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call execute_0Call(String projectId, String queueName, SQLJobRequest sqLJobInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the current queue, the SQL for the use of resources will be used to calculate the resources of the queue. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseJobInfo execute_0(String projectId, String queueName, SQLJobRequest sqLJobInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the current queue, the SQL for the use of resources will be used to calculate the resources of the queue. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseJobInfo> execute_0WithHttpInfo(String projectId, String queueName, SQLJobRequest sqLJobInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the current queue, the SQL for the use of resources will be used to calculate the resources of the queue. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call execute_0Async(String projectId, String queueName, SQLJobRequest sqLJobInfo, String xAuthToken, ApiCallback<ResponseJobInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the current queue, the SQL for the use of resources will be used to calculate the resources of the queue. (required)sqLJobInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call exportDataCall(String projectId, ExportJobRequest exportInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)exportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseJobInfo exportData(String projectId, ExportJobRequest exportInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)exportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseJobInfo> exportDataWithHttpInfo(String projectId, ExportJobRequest exportInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)exportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call exportDataAsync(String projectId, ExportJobRequest exportInfo, String xAuthToken, ApiCallback<ResponseJobInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)exportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getBatchInfoCall(String projectId, String batchId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic SessionInfo getBatchInfo(String projectId, String batchId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<SessionInfo> getBatchInfoWithHttpInfo(String projectId, String batchId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getBatchInfoAsync(String projectId, String batchId, String xAuthToken, ApiCallback<SessionInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call 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) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)clusterName
- (optional)from
- (optional)size
- (optional)jobId
- (optional)jobName
- (optional)start
- (optional)end
- (optional)order
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic SessionInfos getBatchList(String projectId, String xAuthToken, String clusterName, Integer from, Integer size, String jobId, String jobName, Long start, Long end, String order) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)clusterName
- (optional)from
- (optional)size
- (optional)jobId
- (optional)jobName
- (optional)start
- (optional)end
- (optional)order
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<SessionInfos> getBatchListWithHttpInfo(String projectId, String xAuthToken, String clusterName, Integer from, Integer size, String jobId, String jobName, Long start, Long end, String order) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)clusterName
- (optional)from
- (optional)size
- (optional)jobId
- (optional)jobName
- (optional)start
- (optional)end
- (optional)order
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getBatchListAsync(String projectId, String xAuthToken, String clusterName, Integer from, Integer size, String jobId, String jobName, Long start, Long end, String order, ApiCallback<SessionInfos> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)clusterName
- (optional)from
- (optional)size
- (optional)jobId
- (optional)jobName
- (optional)start
- (optional)end
- (optional)order
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getBatchLogCall(String projectId, String batchId, String xAuthToken, Integer from, Integer size, String type, Integer index, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)from
- (optional)size
- (optional)type
- (optional)index
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic SessionLog getBatchLog(String projectId, String batchId, String xAuthToken, Integer from, Integer size, String type, Integer index) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)from
- (optional)size
- (optional)type
- (optional)index
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<SessionLog> getBatchLogWithHttpInfo(String projectId, String batchId, String xAuthToken, Integer from, Integer size, String type, Integer index) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)from
- (optional)size
- (optional)type
- (optional)index
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getBatchLogAsync(String projectId, String batchId, String xAuthToken, Integer from, Integer size, String type, Integer index, ApiCallback<SessionLog> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)from
- (optional)size
- (optional)type
- (optional)index
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getBatchStateCall(String projectId, String batchId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic SessionState getBatchState(String projectId, String batchId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<SessionState> getBatchStateWithHttpInfo(String projectId, String batchId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getBatchStateAsync(String projectId, String batchId, String xAuthToken, ApiCallback<SessionState> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)batchId
- Batch ID. (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getClusterCall(String projectId, String clusterName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ClusterInfo getCluster(String projectId, String clusterName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ClusterInfo> getClusterWithHttpInfo(String projectId, String clusterName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getClusterAsync(String projectId, String clusterName, String xAuthToken, ApiCallback<ClusterInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)clusterName
- Cluster name (required)xAuthToken
- Authorization Token (required)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getFlinkApigSinksCall(String projectId, Long jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic FlinkJobApigSinksResponse getFlinkApigSinks(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<FlinkJobApigSinksResponse> getFlinkApigSinksWithHttpInfo(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getFlinkApigSinksAsync(String projectId, Long jobId, String xAuthToken, ApiCallback<FlinkJobApigSinksResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getFlinkJobDetailCall(String projectId, Long jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GetFlinkJobDetailResponse getFlinkJobDetail(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GetFlinkJobDetailResponse> getFlinkJobDetailWithHttpInfo(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getFlinkJobDetailAsync(String projectId, Long jobId, String xAuthToken, ApiCallback<GetFlinkJobDetailResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getFlinkJobExecuteGraphCall(String projectId, Long jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic FlinkJobExecutePlanResponse getFlinkJobExecuteGraph(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<FlinkJobExecutePlanResponse> getFlinkJobExecuteGraphWithHttpInfo(String projectId, Long jobId, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getFlinkJobExecuteGraphAsync(String projectId, Long jobId, String xAuthToken, ApiCallback<FlinkJobExecutePlanResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- 作业ID (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getFlinkJobTemplatesCall(String projectId, String xAuthToken, Long offset, Integer limit, String order, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)offset
- 作业偏移量 (optional)limit
- 查询条数限制 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic FlinkJobTemplateListResponse getFlinkJobTemplates(String projectId, String xAuthToken, Long offset, Integer limit, String order) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)offset
- 作业偏移量 (optional)limit
- 查询条数限制 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<FlinkJobTemplateListResponse> getFlinkJobTemplatesWithHttpInfo(String projectId, String xAuthToken, Long offset, Integer limit, String order) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)offset
- 作业偏移量 (optional)limit
- 查询条数限制 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getFlinkJobTemplatesAsync(String projectId, String xAuthToken, Long offset, Integer limit, String order, ApiCallback<FlinkJobTemplateListResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)offset
- 作业偏移量 (optional)limit
- 查询条数限制 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call 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) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)name
- 作业名 (optional)status
- 作业状态码, 请参考DLI文档 (optional)queueName
- 队列名称 (optional)showDetail
- 是否返回作业详情信息 (optional, default to false)offset
- 作业偏移量 (optional)limit
- 返回的数据条数 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)rootJobId
- 边缘父作业ID, 用于查询指定边缘作业的子作业; 不带该参数时, 查询所有非边缘作业和边缘父作业, 不包括边缘子作业 (optional)userName
- 用户名,可作为筛选条件 (optional)jobType
- 作业类型 (optional)showJobType
- 显示数据类型,可选spark,flink, all, 默认为all (optional, default to all)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic QueryFlinkJobListResponse 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) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)name
- 作业名 (optional)status
- 作业状态码, 请参考DLI文档 (optional)queueName
- 队列名称 (optional)showDetail
- 是否返回作业详情信息 (optional, default to false)offset
- 作业偏移量 (optional)limit
- 返回的数据条数 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)rootJobId
- 边缘父作业ID, 用于查询指定边缘作业的子作业; 不带该参数时, 查询所有非边缘作业和边缘父作业, 不包括边缘子作业 (optional)userName
- 用户名,可作为筛选条件 (optional)jobType
- 作业类型 (optional)showJobType
- 显示数据类型,可选spark,flink, all, 默认为all (optional, default to all)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<QueryFlinkJobListResponse> 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) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)name
- 作业名 (optional)status
- 作业状态码, 请参考DLI文档 (optional)queueName
- 队列名称 (optional)showDetail
- 是否返回作业详情信息 (optional, default to false)offset
- 作业偏移量 (optional)limit
- 返回的数据条数 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)rootJobId
- 边缘父作业ID, 用于查询指定边缘作业的子作业; 不带该参数时, 查询所有非边缘作业和边缘父作业, 不包括边缘子作业 (optional)userName
- 用户名,可作为筛选条件 (optional)jobType
- 作业类型 (optional)showJobType
- 显示数据类型,可选spark,flink, all, 默认为all (optional, default to all)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call 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) throws ApiException
projectId
- project id, 用于不同project取token. (required)xAuthToken
- Authorization Token (optional)name
- 作业名 (optional)status
- 作业状态码, 请参考DLI文档 (optional)queueName
- 队列名称 (optional)showDetail
- 是否返回作业详情信息 (optional, default to false)offset
- 作业偏移量 (optional)limit
- 返回的数据条数 (optional, default to 10)order
- 查询结果排序, 升序和降序两种可选 (optional, default to desc)rootJobId
- 边缘父作业ID, 用于查询指定边缘作业的子作业; 不带该参数时, 查询所有非边缘作业和边缘父作业, 不包括边缘子作业 (optional)userName
- 用户名,可作为筛选条件 (optional)jobType
- 作业类型 (optional)showJobType
- 显示数据类型,可选spark,flink, all, 默认为all (optional, default to all)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getFlinkJobsMetricsCall(String projectId, GetFlinkJobsMetricsBody getFlinkJobsMetricsBody, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)getFlinkJobsMetricsBody
- 查询作业监控信息, 支持同时查询多个作业监控, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic QueryFlinkJobMetricsResponse getFlinkJobsMetrics(String projectId, GetFlinkJobsMetricsBody getFlinkJobsMetricsBody, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)getFlinkJobsMetricsBody
- 查询作业监控信息, 支持同时查询多个作业监控, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<QueryFlinkJobMetricsResponse> getFlinkJobsMetricsWithHttpInfo(String projectId, GetFlinkJobsMetricsBody getFlinkJobsMetricsBody, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)getFlinkJobsMetricsBody
- 查询作业监控信息, 支持同时查询多个作业监控, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getFlinkJobsMetricsAsync(String projectId, GetFlinkJobsMetricsBody getFlinkJobsMetricsBody, String xAuthToken, ApiCallback<QueryFlinkJobMetricsResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)getFlinkJobsMetricsBody
- 查询作业监控信息, 支持同时查询多个作业监控, 请求参数为json格式 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getImportExportJobInfoCall(String projectId, String jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic DetailResult getImportExportJobInfo(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<DetailResult> getImportExportJobInfoWithHttpInfo(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getImportExportJobInfoAsync(String projectId, String jobId, String xAuthToken, ApiCallback<DetailResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getJobProgressCall(String projectId, String jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobProgressResult getJobProgress(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobProgressResult> getJobProgressWithHttpInfo(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getJobProgressAsync(String projectId, String jobId, String xAuthToken, ApiCallback<JobProgressResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getJobResultCall(String projectId, String jobId, String xAuthToken, Integer pageSize, Integer currentPage, String queueName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)queueName
- The DLI queue that executed this API request. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobResult getJobResult(String projectId, String jobId, String xAuthToken, Integer pageSize, Integer currentPage, String queueName) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)queueName
- The DLI queue that executed this API request. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobResult> getJobResultWithHttpInfo(String projectId, String jobId, String xAuthToken, Integer pageSize, Integer currentPage, String queueName) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)queueName
- The DLI queue that executed this API request. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getJobResultAsync(String projectId, String jobId, String xAuthToken, Integer pageSize, Integer currentPage, String queueName, ApiCallback<JobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)queueName
- The DLI queue that executed this API request. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getJobResult_0Call(String projectId, String queueName, String jobId, String xAuthToken, Integer pageSize, Integer currentPage, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobResult getJobResult_0(String projectId, String queueName, String jobId, String xAuthToken, Integer pageSize, Integer currentPage) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobResult> getJobResult_0WithHttpInfo(String projectId, String queueName, String jobId, String xAuthToken, Integer pageSize, Integer currentPage) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getJobResult_0Async(String projectId, String queueName, String jobId, String xAuthToken, Integer pageSize, Integer currentPage, ApiCallback<JobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The current queue name, the SQL will use the current queue resources to calculate. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getJobStatusCall(String projectId, String jobId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic StatusResult getJobStatus(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<StatusResult> getJobStatusWithHttpInfo(String projectId, String jobId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getJobStatusAsync(String projectId, String jobId, String xAuthToken, ApiCallback<StatusResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getResourceInfoCall(String projectId, String resourceName, String group, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic PkgResourceInfo getResourceInfo(String projectId, String resourceName, String group, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<PkgResourceInfo> getResourceInfoWithHttpInfo(String projectId, String resourceName, String group, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getResourceInfoAsync(String projectId, String resourceName, String group, String xAuthToken, ApiCallback<PkgResourceInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)resourceName
- Resource name. (required)group
- Resource group. (optional)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getSpecifiedQueueCall(String projectId, String queueName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic QueueInfo getSpecifiedQueue(String projectId, String queueName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<QueueInfo> getSpecifiedQueueWithHttpInfo(String projectId, String queueName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getSpecifiedQueueAsync(String projectId, String queueName, String xAuthToken, ApiCallback<QueueInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getTsdbByIdCall(String projectId, Long tsdbId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- 项目ID (required)tsdbId
- 时序数据库的ID (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GetTsdbByIdResp getTsdbById(String projectId, Long tsdbId, String xAuthToken) throws ApiException
projectId
- 项目ID (required)tsdbId
- 时序数据库的ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GetTsdbByIdResp> getTsdbByIdWithHttpInfo(String projectId, Long tsdbId, String xAuthToken) throws ApiException
projectId
- 项目ID (required)tsdbId
- 时序数据库的ID (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getTsdbByIdAsync(String projectId, Long tsdbId, String xAuthToken, ApiCallback<GetTsdbByIdResp> callback) throws ApiException
projectId
- 项目ID (required)tsdbId
- 时序数据库的ID (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call getTsdbListCall(String projectId, Integer offset, Integer limit, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- (required)offset
- 偏移量 (optional, default to 0)limit
- 每页的数量 (optional, default to 10)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GetTsdbListResp getTsdbList(String projectId, Integer offset, Integer limit, String xAuthToken) throws ApiException
projectId
- (required)offset
- 偏移量 (optional, default to 0)limit
- 每页的数量 (optional, default to 10)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GetTsdbListResp> getTsdbListWithHttpInfo(String projectId, Integer offset, Integer limit, String xAuthToken) throws ApiException
projectId
- (required)offset
- 偏移量 (optional, default to 0)limit
- 每页的数量 (optional, default to 10)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call getTsdbListAsync(String projectId, Integer offset, Integer limit, String xAuthToken, ApiCallback<GetTsdbListResp> callback) throws ApiException
projectId
- (required)offset
- 偏移量 (optional, default to 0)limit
- 每页的数量 (optional, default to 10)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call importDataCall(String projectId, ImportJobRequest importExportInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)importExportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseJobInfo importData(String projectId, ImportJobRequest importExportInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)importExportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseJobInfo> importDataWithHttpInfo(String projectId, ImportJobRequest importExportInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)importExportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call importDataAsync(String projectId, ImportJobRequest importExportInfo, String xAuthToken, ApiCallback<ResponseJobInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)importExportInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listAllDatabasesCall(String projectId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic DatabaseResult listAllDatabases(String projectId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<DatabaseResult> listAllDatabasesWithHttpInfo(String projectId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listAllDatabasesAsync(String projectId, String xAuthToken, ApiCallback<DatabaseResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call 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) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)start
- (optional)end
- (optional)jobType
- (optional)tags
- (optional)queueName
- (optional)owner
- (optional)jobStatus
- (optional)order
- 查询结果排序, 升序和降序两种可选 (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobListResult 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) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)start
- (optional)end
- (optional)jobType
- (optional)tags
- (optional)queueName
- (optional)owner
- (optional)jobStatus
- (optional)order
- 查询结果排序, 升序和降序两种可选 (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobListResult> 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) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)start
- (optional)end
- (optional)jobType
- (optional)tags
- (optional)queueName
- (optional)owner
- (optional)jobStatus
- (optional)order
- 查询结果排序, 升序和降序两种可选 (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call 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) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)start
- (optional)end
- (optional)jobType
- (optional)tags
- (optional)queueName
- (optional)owner
- (optional)jobStatus
- (optional)order
- 查询结果排序, 升序和降序两种可选 (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listAllQueuesCall(String projectId, String xAuthToken, String queueType, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)queueType
- Queue Type (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic QueueResult listAllQueues(String projectId, String xAuthToken, String queueType) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)queueType
- Queue Type (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<QueueResult> listAllQueuesWithHttpInfo(String projectId, String xAuthToken, String queueType) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)queueType
- Queue Type (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listAllQueuesAsync(String projectId, String xAuthToken, String queueType, ApiCallback<QueueResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)queueType
- Queue Type (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listAllTablesCall(String projectId, String databaseName, String xAuthToken, String keyword, Boolean withDetail, Integer pageSize, Integer currentPage, String tableType, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- View the database where the table name. (required)xAuthToken
- Authorization Token. (optional)keyword
- Keywords for filtering table names. (optional)withDetail
- Whether to get the details of the table (owner, size, etc.). (optional)pageSize
- (optional)currentPage
- (optional)tableType
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic TableListResult listAllTables(String projectId, String databaseName, String xAuthToken, String keyword, Boolean withDetail, Integer pageSize, Integer currentPage, String tableType) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- View the database where the table name. (required)xAuthToken
- Authorization Token. (optional)keyword
- Keywords for filtering table names. (optional)withDetail
- Whether to get the details of the table (owner, size, etc.). (optional)pageSize
- (optional)currentPage
- (optional)tableType
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<TableListResult> listAllTablesWithHttpInfo(String projectId, String databaseName, String xAuthToken, String keyword, Boolean withDetail, Integer pageSize, Integer currentPage, String tableType) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- View the database where the table name. (required)xAuthToken
- Authorization Token. (optional)keyword
- Keywords for filtering table names. (optional)withDetail
- Whether to get the details of the table (owner, size, etc.). (optional)pageSize
- (optional)currentPage
- (optional)tableType
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listAllTablesAsync(String projectId, String databaseName, String xAuthToken, String keyword, Boolean withDetail, Integer pageSize, Integer currentPage, String tableType, ApiCallback<TableListResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- View the database where the table name. (required)xAuthToken
- Authorization Token. (optional)keyword
- Keywords for filtering table names. (optional)withDetail
- Whether to get the details of the table (owner, size, etc.). (optional)pageSize
- (optional)currentPage
- (optional)tableType
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listClusterCall(String projectId, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ClusterInfos listCluster(String projectId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ClusterInfos> listClusterWithHttpInfo(String projectId, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listClusterAsync(String projectId, String xAuthToken, ApiCallback<ClusterInfos> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listDatabaseUsersCall(String projectId, String databaseName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic PrivilegeResult listDatabaseUsers(String projectId, String databaseName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<PrivilegeResult> listDatabaseUsersWithHttpInfo(String projectId, String databaseName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listDatabaseUsersAsync(String projectId, String databaseName, String xAuthToken, ApiCallback<PrivilegeResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listQueueUsersCall(String projectId, String queueName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic PrivilegeResult listQueueUsers(String projectId, String queueName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<PrivilegeResult> listQueueUsersWithHttpInfo(String projectId, String queueName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listQueueUsersAsync(String projectId, String queueName, String xAuthToken, ApiCallback<PrivilegeResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)queueName
- The name of the queue (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listResourcesCall(String projectId, String xAuthToken, String kind, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)kind
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResourceInfos listResources(String projectId, String xAuthToken, String kind) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)kind
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResourceInfos> listResourcesWithHttpInfo(String projectId, String xAuthToken, String kind) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)kind
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listResourcesAsync(String projectId, String xAuthToken, String kind, ApiCallback<ResourceInfos> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token (optional)kind
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listSqlJobsCall(String projectId, String xAuthToken, Integer pageSize, Integer currentPage, String tags, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)tags
- (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobListResult listSqlJobs(String projectId, String xAuthToken, Integer pageSize, Integer currentPage, String tags) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)tags
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobListResult> listSqlJobsWithHttpInfo(String projectId, String xAuthToken, Integer pageSize, Integer currentPage, String tags) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)tags
- (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listSqlJobsAsync(String projectId, String xAuthToken, Integer pageSize, Integer currentPage, String tags, ApiCallback<JobListResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)xAuthToken
- Authorization Token. (optional)pageSize
- The maximum number of rows displayed per page,in the range: [1, 100]. The default is: 10. (optional)currentPage
- The current page number, the default is the first page. (optional)tags
- (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listTableUserPrivilegesCall(String projectId, String databaseName, String tableName, String userName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried. (required)tableName
- The name of the table to be queried. (required)userName
- The name of the user to be queried. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic PrivilegeResult listTableUserPrivileges(String projectId, String databaseName, String tableName, String userName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried. (required)tableName
- The name of the table to be queried. (required)userName
- The name of the user to be queried. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<PrivilegeResult> listTableUserPrivilegesWithHttpInfo(String projectId, String databaseName, String tableName, String userName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried. (required)tableName
- The name of the table to be queried. (required)userName
- The name of the user to be queried. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listTableUserPrivilegesAsync(String projectId, String databaseName, String tableName, String userName, String xAuthToken, ApiCallback<PrivilegeResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried. (required)tableName
- The name of the table to be queried. (required)userName
- The name of the user to be queried. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call listTableUsersCall(String projectId, String databaseName, String tableName, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)tableName
- The name of the table to be queried. (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic PrivilegeResult listTableUsers(String projectId, String databaseName, String tableName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)tableName
- The name of the table to be queried. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<PrivilegeResult> listTableUsersWithHttpInfo(String projectId, String databaseName, String tableName, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)tableName
- The name of the table to be queried. (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call listTableUsersAsync(String projectId, String databaseName, String tableName, String xAuthToken, ApiCallback<PrivilegeResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The database name to be queried.. (required)tableName
- The name of the table to be queried. (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call previewJobResultCall(String projectId, String jobId, String xAuthToken, String queueName, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)queueName
- The DLI queue that executed this API request. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobResult previewJobResult(String projectId, String jobId, String xAuthToken, String queueName) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)queueName
- The DLI queue that executed this API request. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobResult> previewJobResultWithHttpInfo(String projectId, String jobId, String xAuthToken, String queueName) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)queueName
- The DLI queue that executed this API request. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call previewJobResultAsync(String projectId, String jobId, String xAuthToken, String queueName, ApiCallback<JobResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)queueName
- The DLI queue that executed this API request. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call queueActionCall(String projectId, String queueName, QueueActionRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)queueName
- queue名称,指定queue (required)body
- 队列操作请求体, 请求参数为json格式 (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic QueueActionResponse queueAction(String projectId, String queueName, QueueActionRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)queueName
- queue名称,指定queue (required)body
- 队列操作请求体, 请求参数为json格式 (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<QueueActionResponse> queueActionWithHttpInfo(String projectId, String queueName, QueueActionRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)queueName
- queue名称,指定queue (required)body
- 队列操作请求体, 请求参数为json格式 (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call queueActionAsync(String projectId, String queueName, QueueActionRequest body, String xAuthToken, ApiCallback<QueueActionResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)queueName
- queue名称,指定queue (required)body
- 队列操作请求体, 请求参数为json格式 (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call runFlinkJobCall(String projectId, RunFlinkJobRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic List<GlobalBatchResponse> runFlinkJob(String projectId, RunFlinkJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<List<GlobalBatchResponse>> runFlinkJobWithHttpInfo(String projectId, RunFlinkJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call runFlinkJobAsync(String projectId, RunFlinkJobRequest body, String xAuthToken, ApiCallback<List<GlobalBatchResponse>> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call shareQueueCall(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseInfo shareQueue(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseInfo> shareQueueWithHttpInfo(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call shareQueueAsync(String projectId, PrivilegeInfo privilegeInfo, String xAuthToken, ApiCallback<ResponseInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)privilegeInfo
- Request parameters (required)xAuthToken
- Authorization Token. (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call showPartitionsCall(String projectId, String databaseName, String tableName, String xAuthToken, Integer offset, Integer limit, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)offset
- The offset of the table to be set. (optional, default to 0)limit
- The limit of the table to be set. (optional, default to 100)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic PartitionResult showPartitions(String projectId, String databaseName, String tableName, String xAuthToken, Integer offset, Integer limit) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)offset
- The offset of the table to be set. (optional, default to 0)limit
- The limit of the table to be set. (optional, default to 100)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<PartitionResult> showPartitionsWithHttpInfo(String projectId, String databaseName, String tableName, String xAuthToken, Integer offset, Integer limit) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)offset
- The offset of the table to be set. (optional, default to 0)limit
- The limit of the table to be set. (optional, default to 100)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call showPartitionsAsync(String projectId, String databaseName, String tableName, String xAuthToken, Integer offset, Integer limit, ApiCallback<PartitionResult> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)databaseName
- The name of the database where the table to be described is located. (required)tableName
- The name of the table to be described. (required)xAuthToken
- Authorization Token. (optional)offset
- The offset of the table to be set. (optional, default to 0)limit
- The limit of the table to be set. (optional, default to 100)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call stopFlinkJobCall(String projectId, StopFlinkJobRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic List<GlobalBatchResponse> stopFlinkJob(String projectId, StopFlinkJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<List<GlobalBatchResponse>> stopFlinkJobWithHttpInfo(String projectId, StopFlinkJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call stopFlinkJobAsync(String projectId, StopFlinkJobRequest body, String xAuthToken, ApiCallback<List<GlobalBatchResponse>> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call storeJobResultCall(String projectId, String jobId, String xAuthToken, ExportCommonInfo exportCommonInfo, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)exportCommonInfo
- Request parameters (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResponseJobInfo storeJobResult(String projectId, String jobId, String xAuthToken, ExportCommonInfo exportCommonInfo) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)exportCommonInfo
- Request parameters (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResponseJobInfo> storeJobResultWithHttpInfo(String projectId, String jobId, String xAuthToken, ExportCommonInfo exportCommonInfo) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)exportCommonInfo
- Request parameters (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call storeJobResultAsync(String projectId, String jobId, String xAuthToken, ExportCommonInfo exportCommonInfo, ApiCallback<ResponseJobInfo> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)jobId
- Job ID. (required)xAuthToken
- Authorization Token. (optional)exportCommonInfo
- Request parameters (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call submitFlinkJarJobCall(String projectId, CreateFlinkJarJobRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobStatusResponse submitFlinkJarJob(String projectId, CreateFlinkJarJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobStatusResponse> submitFlinkJarJobWithHttpInfo(String projectId, CreateFlinkJarJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call submitFlinkJarJobAsync(String projectId, CreateFlinkJarJobRequest body, String xAuthToken, ApiCallback<JobStatusResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call submitFlinkSqlJobCall(String projectId, SubmitFlinkSqlJobRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobStatusResponse submitFlinkSqlJob(String projectId, SubmitFlinkSqlJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobStatusResponse> submitFlinkSqlJobWithHttpInfo(String projectId, SubmitFlinkSqlJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call submitFlinkSqlJobAsync(String projectId, SubmitFlinkSqlJobRequest body, String xAuthToken, ApiCallback<JobStatusResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call updateFlinkJarJobCall(String projectId, Long jobId, UpdateFlinkJarJobRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobUpdateResponse updateFlinkJarJob(String projectId, Long jobId, UpdateFlinkJarJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobUpdateResponse> updateFlinkJarJobWithHttpInfo(String projectId, Long jobId, UpdateFlinkJarJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call updateFlinkJarJobAsync(String projectId, Long jobId, UpdateFlinkJarJobRequest body, String xAuthToken, ApiCallback<JobUpdateResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- JSON格式的请求体 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call updateFlinkJobTemplateCall(String projectId, Long templateId, UpdateFlinkJobTemplateRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)body
- 提交修改SQL作业模板请求 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GlobalResponse updateFlinkJobTemplate(String projectId, Long templateId, UpdateFlinkJobTemplateRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)body
- 提交修改SQL作业模板请求 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GlobalResponse> updateFlinkJobTemplateWithHttpInfo(String projectId, Long templateId, UpdateFlinkJobTemplateRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)body
- 提交修改SQL作业模板请求 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call updateFlinkJobTemplateAsync(String projectId, Long templateId, UpdateFlinkJobTemplateRequest body, String xAuthToken, ApiCallback<GlobalResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)templateId
- (required)body
- 提交修改SQL作业模板请求 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call updateFlinkSqlJobCall(String projectId, Long jobId, UpdateFlinkSqlJobRequest body, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- 提交修改SQL作业请求 (required)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic JobUpdateResponse updateFlinkSqlJob(String projectId, Long jobId, UpdateFlinkSqlJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- 提交修改SQL作业请求 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<JobUpdateResponse> updateFlinkSqlJobWithHttpInfo(String projectId, Long jobId, UpdateFlinkSqlJobRequest body, String xAuthToken) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- 提交修改SQL作业请求 (required)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call updateFlinkSqlJobAsync(String projectId, Long jobId, UpdateFlinkSqlJobRequest body, String xAuthToken, ApiCallback<JobUpdateResponse> callback) throws ApiException
projectId
- project id, 用于不同project取token. (required)jobId
- (required)body
- 提交修改SQL作业请求 (required)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call updateTsdbCall(String projectId, String tsdbId, UpdateTsdbReq updateTsdbReq, String xAuthToken, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- (required)tsdbId
- (required)updateTsdbReq
- This is a auto create Body Object (optional)xAuthToken
- Authorization Token (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic GlobalResponse updateTsdb(String projectId, String tsdbId, UpdateTsdbReq updateTsdbReq, String xAuthToken) throws ApiException
projectId
- (required)tsdbId
- (required)updateTsdbReq
- This is a auto create Body Object (optional)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<GlobalResponse> updateTsdbWithHttpInfo(String projectId, String tsdbId, UpdateTsdbReq updateTsdbReq, String xAuthToken) throws ApiException
projectId
- (required)tsdbId
- (required)updateTsdbReq
- This is a auto create Body Object (optional)xAuthToken
- Authorization Token (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call updateTsdbAsync(String projectId, String tsdbId, UpdateTsdbReq updateTsdbReq, String xAuthToken, ApiCallback<GlobalResponse> callback) throws ApiException
projectId
- (required)tsdbId
- (required)updateTsdbReq
- This is a auto create Body Object (optional)xAuthToken
- Authorization Token (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call uploadFilesCall(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResourceMsg uploadFiles(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResourceMsg> uploadFilesWithHttpInfo(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call uploadFilesAsync(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ApiCallback<ResourceMsg> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call uploadJarsCall(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResourceMsg uploadJars(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResourceMsg> uploadJarsWithHttpInfo(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call uploadJarsAsync(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ApiCallback<ResourceMsg> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call uploadPyFilesCall(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResourceMsg uploadPyFiles(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResourceMsg> uploadPyFilesWithHttpInfo(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call uploadPyFilesAsync(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ApiCallback<ResourceMsg> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectpublic okhttp3.Call uploadResourcesCall(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ProgressResponseBody.ProgressListener progressListener, ProgressRequestBody.ProgressRequestListener progressRequestListener) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)progressListener
- Progress listenerprogressRequestListener
- Progress request listenerApiException
- If fail to serialize the request body objectpublic ResourceMsg uploadResources(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic ApiResponse<ResourceMsg> uploadResourcesWithHttpInfo(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)ApiException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic okhttp3.Call uploadResourcesAsync(String projectId, PkgResourceRequest body, String xAuthToken, String USER_ID, ApiCallback<ResourceMsg> callback) throws ApiException
projectId
- Project ID for resource isolation. (required)body
- (required)xAuthToken
- Authorization Token (optional)USER_ID
- Real user id (optional)callback
- The callback to be executed when the API call finishesApiException
- If fail to process the API call, e.g. serializing the request body objectCopyright © 2023. All rights reserved.