public interface DispatcherGateway extends FencedRpcGateway<DispatcherId>, RestfulGateway
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
cancelJob(JobID jobId,
Time timeout)
Cancel the given job.
|
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<Acknowledge> |
stopJob(JobID jobId,
Time timeout)
Stop the given job.
|
CompletableFuture<Acknowledge> |
submitJob(JobGraph jobGraph,
Time timeout)
Submit a job to the dispatcher.
|
getFencingToken
requestClusterOverview, requestJob, requestJobDetails, requestMetricQueryServicePaths, requestRestAddress, requestTaskManagerMetricQueryServicePaths
getAddress, getHostname
CompletableFuture<Acknowledge> submitJob(JobGraph jobGraph, Time timeout)
jobGraph
- JobGraph to submittimeout
- RPC timeoutCompletableFuture<Collection<JobID>> listJobs(Time timeout)
timeout
- RPC timeoutCompletableFuture<Acknowledge> cancelJob(JobID jobId, Time timeout)
jobId
- identifying the job to canceltimeout
- of the operationCompletableFuture<Acknowledge> stopJob(JobID jobId, Time timeout)
jobId
- identifying the job to stoptimeout
- of the operationCompletableFuture<Integer> getBlobServerPort(Time timeout)
timeout
- of the operationCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.