Package | Description |
---|---|
com.huawei.dli.restapi.api | |
com.huawei.dli.restapi.model |
Modifier and Type | Method and Description |
---|---|
JobUpdateResponse |
RestApi.updateFlinkJarJob(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken)
更新用户自定义Flink作业
目前仅支持Jar格式, 运行在独享集群中
|
JobUpdateResponse |
RestApi.updateFlinkSqlJob(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken)
更新流式SQL作业
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
Modifier and Type | Method and Description |
---|---|
ApiResponse<JobUpdateResponse> |
RestApi.updateFlinkJarJobWithHttpInfo(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken)
更新用户自定义Flink作业
目前仅支持Jar格式, 运行在独享集群中
|
ApiResponse<JobUpdateResponse> |
RestApi.updateFlinkSqlJobWithHttpInfo(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken)
更新流式SQL作业
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
Modifier and Type | Method and Description |
---|---|
okhttp3.Call |
RestApi.updateFlinkJarJobAsync(String projectId,
Long jobId,
UpdateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新用户自定义Flink作业 (asynchronously)
目前仅支持Jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.updateFlinkSqlJobAsync(String projectId,
Long jobId,
UpdateFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobUpdateResponse> callback)
更新流式SQL作业 (asynchronously)
流式SQL的语法扩展了Apache Flink SQL, 具体详情请参考DLI官方文档
|
Modifier and Type | Method and Description |
---|---|
JobUpdateResponse |
JobUpdateResponse.isSuccess(Boolean isSuccess) |
JobUpdateResponse |
JobUpdateResponse.job(JobUpdateTime job) |
JobUpdateResponse |
JobUpdateResponse.message(String message) |
Copyright © 2023. All rights reserved.