org.apache.flink.client.deployment.application

类 WebSubmissionJobClient

java.lang.Object

org.apache.flink.client.deployment.application.WebSubmissionJobClient

所有已实现的接口:

org.apache.flink.core.execution.JobClient

@PublicEvolving
public class WebSubmissionJobClient
extends Object
implements org.apache.flink.core.execution.JobClient

A JobClient that only allows asking for the job id of the job it is attached to.

This is used in web submission, where we do not want the Web UI to have jobs blocking threads while waiting for their completion.

构造器概要

构造器

构造器和说明
WebSubmissionJobClient(org.apache.flink.api.common.JobID jobId)

方法概要

限定符和类型	方法和说明
CompletableFuture<Void>	cancel()
CompletableFuture<Map<String,Object>>	getAccumulators(ClassLoader classLoader)
CompletableFuture<org.apache.flink.api.common.JobExecutionResult>	getJobExecutionResult(ClassLoader userClassloader)
org.apache.flink.api.common.JobID	getJobID()
CompletableFuture<org.apache.flink.api.common.JobStatus>	getJobStatus()
CompletableFuture<String>	stopWithSavepoint(boolean advanceToEndOfEventTime, String savepointDirectory)
CompletableFuture<String>	triggerSavepoint(String savepointDirectory)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

WebSubmissionJobClient

public WebSubmissionJobClient(org.apache.flink.api.common.JobID jobId)

方法详细资料

getJobID

public org.apache.flink.api.common.JobID getJobID()

指定者:

getJobID 在接口中 org.apache.flink.core.execution.JobClient

getJobStatus

public CompletableFuture<org.apache.flink.api.common.JobStatus> getJobStatus()

指定者:

getJobStatus 在接口中 org.apache.flink.core.execution.JobClient

cancel

public CompletableFuture<Void> cancel()

指定者:

cancel 在接口中 org.apache.flink.core.execution.JobClient

stopWithSavepoint

public CompletableFuture<String> stopWithSavepoint(boolean advanceToEndOfEventTime,
                                                   @Nullable
                                                   String savepointDirectory)

指定者:

stopWithSavepoint 在接口中 org.apache.flink.core.execution.JobClient

triggerSavepoint

public CompletableFuture<String> triggerSavepoint(@Nullable
                                                  String savepointDirectory)

指定者:

triggerSavepoint 在接口中 org.apache.flink.core.execution.JobClient

getAccumulators

public CompletableFuture<Map<String,Object>> getAccumulators(ClassLoader classLoader)

指定者:

getAccumulators 在接口中 org.apache.flink.core.execution.JobClient

getJobExecutionResult

public CompletableFuture<org.apache.flink.api.common.JobExecutionResult> getJobExecutionResult(ClassLoader userClassloader)

指定者:

getJobExecutionResult 在接口中 org.apache.flink.core.execution.JobClient