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格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.submitFlinkJarJobAsync(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ApiCallback<JobStatusResponse> callback)
创建一个用户自定义Flink作业 (asynchronously)
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
okhttp3.Call |
RestApi.submitFlinkJarJobCall(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken,
ProgressResponseBody.ProgressListener progressListener,
ProgressRequestBody.ProgressRequestListener progressRequestListener)
Build call for submitFlinkJarJob
|
ApiResponse<JobStatusResponse> |
RestApi.submitFlinkJarJobWithHttpInfo(String projectId,
CreateFlinkJarJobRequest body,
String xAuthToken)
创建一个用户自定义Flink作业
用户自定义Flink作业目前支持jar格式, 运行在独享集群中
|
Copyright © 2023. All rights reserved.