public final class DispatcherJob extends Object implements AutoCloseableAsync
Dispatcher
to manage jobs.Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
cancel(Time timeout)
Cancel job.
|
CompletableFuture<Void> |
closeAsync()
Trigger the closing of the resource and return the corresponding close future.
|
CompletableFuture<JobMasterGateway> |
getJobMasterGateway()
Returns the
JobMasterGateway from the JobManagerRunner. |
CompletableFuture<org.apache.flink.runtime.dispatcher.DispatcherJobResult> |
getResultFuture() |
boolean |
isInitialized()
The job is initialized once the JobManager runner has been initialized.
|
CompletableFuture<ArchivedExecutionGraph> |
requestJob(Time timeout)
Returns a future completing to the ArchivedExecutionGraph of the job.
|
CompletableFuture<JobDetails> |
requestJobDetails(Time timeout) |
CompletableFuture<JobStatus> |
requestJobStatus(Time timeout) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public CompletableFuture<org.apache.flink.runtime.dispatcher.DispatcherJobResult> getResultFuture()
public CompletableFuture<JobDetails> requestJobDetails(Time timeout)
public CompletableFuture<Acknowledge> cancel(Time timeout)
public CompletableFuture<JobStatus> requestJobStatus(Time timeout)
public CompletableFuture<ArchivedExecutionGraph> requestJob(Time timeout)
public boolean isInitialized()
public CompletableFuture<JobMasterGateway> getJobMasterGateway()
JobMasterGateway
from the JobManagerRunner.JobMasterGateway
. The future will complete exceptionally if the
JobManagerRunner initialization failed.IllegalStateException
- is thrown if the job is not initializedpublic CompletableFuture<Void> closeAsync()
AutoCloseableAsync
closeAsync
in interface AutoCloseableAsync
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.