Package | Description |
---|---|
com.huawei.dli.restapi.api | |
com.huawei.dli.restapi.model |
Modifier and Type | Method and Description |
---|---|
JobStatusResponse |
RestApi.submitFlinkJarJob(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
JobStatusResponse |
RestApi.submitFlinkSqlJob(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken)
提交流式SQL作业到DLI服务
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
Modifier and Type | Method and Description |
---|---|
ApiResponse<JobStatusResponse> |
RestApi.submitFlinkJarJobWithHttpInfo(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
ApiResponse<JobStatusResponse> |
RestApi.submitFlinkSqlJobWithHttpInfo(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken)
提交流式SQL作业到DLI服务
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
Modifier and Type | Method and Description |
---|---|
okhttp3.Call |
RestApi.submitFlinkJarJobAsync(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
创建一个用户自定义Flink作业 (asynchronously)
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.submitFlinkSqlJobAsync(String projectId,
SubmitFlinkSqlJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
提交流式SQL作业到DLI服务 (asynchronously)
通过POST方式, 提交流式SQL作业, 请求体为JSON格式
|
Modifier and Type | Method and Description |
---|---|
JobStatusResponse |
JobStatusResponse.isSuccess(Boolean isSuccess) |
JobStatusResponse |
JobStatusResponse.job(JobStatusInfo job) |
JobStatusResponse |
JobStatusResponse.message(String message) |
Copyright © 2023. All rights reserved.