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.
|
default CompletableFuture<Acknowledge> |
shutDownCluster(ApplicationStatus applicationStatus) |
CompletableFuture<Acknowledge> |
submitJob(JobGraph jobGraph,
Time timeout)
Submit a job to the dispatcher.
|
getFencingToken
cancelJob, deliverCoordinationRequestToCoordinator, disposeSavepoint, requestClusterOverview, requestExecutionGraphInfo, requestJob, requestJobResult, requestJobStatus, requestMetricQueryServiceAddresses, requestMultipleJobDetails, requestTaskManagerMetricQueryServiceAddresses, shutDownCluster, stopWithSavepoint, 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 operationdefault CompletableFuture<Acknowledge> shutDownCluster(ApplicationStatus applicationStatus)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.