public interface DispatcherGateway extends FencedRpcGateway<DispatcherId>, RestfulGateway
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Integer> |
getBlobServerPort(Time timeout)
Returns the port of the blob server.
|
CompletableFuture<Collection<JobID>> |
listJobs(Time timeout)
List the current set of submitted jobs.
|
CompletableFuture<ArchivedExecutionGraph> |
requestJob(JobID jobId,
Time timeout)
Requests the
ArchivedExecutionGraph for the given jobId. |
CompletableFuture<Acknowledge> |
submitJob(JobGraph jobGraph,
Time timeout)
Submit a job to the dispatcher.
|
getFencingToken
cancelJob, disposeSavepoint, requestClusterOverview, requestJobResult, requestJobStatus, requestMetricQueryServicePaths, requestMultipleJobDetails, requestOperatorBackPressureStats, requestTaskManagerMetricQueryServicePaths, rescaleJob, shutDownCluster, stopJob, triggerSavepoint
getAddress, getHostname
CompletableFuture<Acknowledge> submitJob(JobGraph jobGraph, Time timeout)
jobGraph
- JobGraph to submittimeout
- RPC timeoutCompletableFuture<Collection<JobID>> listJobs(Time timeout)
timeout
- RPC timeoutCompletableFuture<Integer> getBlobServerPort(Time timeout)
timeout
- of the operationCompletableFuture<ArchivedExecutionGraph> requestJob(JobID jobId, Time timeout)
ArchivedExecutionGraph
for the given jobId. If there is no such graph, then
the future is completed with a FlinkJobNotFoundException
.
Note: We enforce that the returned future contains a ArchivedExecutionGraph
unlike
the super interface.
requestJob
in interface RestfulGateway
jobId
- identifying the job whose AccessExecutionGraph is requestedtimeout
- for the asynchronous operationFlinkJobNotFoundException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.