public class AkkaJobManagerGateway extends Object implements JobManagerGateway
JobManagerGateway
for old JobManager code based
on Akka actors and the ActorGateway
.Constructor and Description |
---|
AkkaJobManagerGateway(ActorGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
cancelJob(JobID jobId,
Time timeout)
Cancels the given job.
|
CompletableFuture<String> |
cancelJobWithSavepoint(JobID jobId,
String savepointPath,
Time timeout)
Cancels the given job after taking a savepoint and returning its path.
|
String |
getAddress()
Returns the fully qualified address under which the associated rpc endpoint is reachable.
|
String |
getHostname()
Returns the fully qualified hostname under which the associated rpc endpoint is reachable.
|
CompletableFuture<Integer> |
requestBlobServerPort(Time timeout)
Requests the BlobServer port.
|
CompletableFuture<Optional<org.apache.flink.runtime.messages.JobManagerMessages.ClassloadingProps>> |
requestClassloadingProps(JobID jobId,
Time timeout)
Requests the class loading properties for the given JobID.
|
CompletableFuture<ClusterOverview> |
requestClusterOverview(Time timeout)
Requests the cluster status overview.
|
CompletableFuture<AccessExecutionGraph> |
requestJob(JobID jobId,
Time timeout)
Requests the
AccessExecutionGraph for the given jobId. |
CompletableFuture<JobResult> |
requestJobResult(JobID jobId,
Time timeout)
Requests the
JobResult of a job specified by the given jobId. |
CompletableFuture<JobIdsWithStatusOverview> |
requestJobsOverview(Time timeout)
Requests the job overview from the JobManager.
|
CompletableFuture<Collection<String>> |
requestMetricQueryServicePaths(Time timeout)
Requests the paths for the
MetricQueryService to query. |
CompletableFuture<MultipleJobsDetails> |
requestMultipleJobDetails(Time timeout)
Requests job details currently being executed on the Flink cluster.
|
CompletableFuture<String> |
requestRestAddress(Time timeout)
Requests the REST address of this
RpcEndpoint . |
CompletableFuture<Optional<Instance>> |
requestTaskManagerInstance(ResourceID resourceId,
Time timeout)
Requests the TaskManager instance registered under the given instanceId from the JobManager.
|
CompletableFuture<Collection<Instance>> |
requestTaskManagerInstances(Time timeout)
Requests all currently registered TaskManager instances from the JobManager.
|
CompletableFuture<Collection<Tuple2<ResourceID,String>>> |
requestTaskManagerMetricQueryServicePaths(Time timeout)
Requests the paths for the TaskManager's
MetricQueryService to query. |
CompletableFuture<Acknowledge> |
stopJob(JobID jobId,
Time timeout)
Stops the given job.
|
CompletableFuture<Acknowledge> |
submitJob(JobGraph jobGraph,
ListeningBehaviour listeningBehaviour,
Time timeout)
Submits a job to the JobManager.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disposeSavepoint, requestJobStatus, requestOperatorBackPressureStats, rescaleJob, shutDownCluster, triggerSavepoint
public AkkaJobManagerGateway(ActorGateway jobManagerGateway)
public String getAddress()
RpcGateway
getAddress
in interface RpcGateway
public String getHostname()
RpcGateway
getHostname
in interface RpcGateway
public CompletableFuture<Integer> requestBlobServerPort(Time timeout)
JobManagerGateway
requestBlobServerPort
in interface JobManagerGateway
timeout
- for this operationpublic CompletableFuture<Acknowledge> submitJob(JobGraph jobGraph, ListeningBehaviour listeningBehaviour, Time timeout)
JobManagerGateway
submitJob
in interface JobManagerGateway
jobGraph
- to submitlisteningBehaviour
- of the clienttimeout
- for this operationpublic CompletableFuture<String> cancelJobWithSavepoint(JobID jobId, String savepointPath, Time timeout)
JobManagerGateway
cancelJobWithSavepoint
in interface JobManagerGateway
jobId
- identifying the job to cancelsavepointPath
- Optional path for the savepoint to be stored under; if null, then the default path is
takentimeout
- for the asynchronous operationpublic CompletableFuture<Acknowledge> cancelJob(JobID jobId, Time timeout)
JobManagerGateway
cancelJob
in interface JobManagerGateway
cancelJob
in interface RestfulGateway
jobId
- identifying the job to canceltimeout
- for the asynchronous operationpublic CompletableFuture<Acknowledge> stopJob(JobID jobId, Time timeout)
JobManagerGateway
stopJob
in interface JobManagerGateway
stopJob
in interface RestfulGateway
jobId
- identifying the job to canceltimeout
- for the asynchronous operationpublic CompletableFuture<Optional<Instance>> requestTaskManagerInstance(ResourceID resourceId, Time timeout)
JobManagerGateway
Optional.empty()
is returned.requestTaskManagerInstance
in interface JobManagerGateway
resourceId
- identifying the TaskManager which shall be retrievedtimeout
- for the asynchronous operationOptional.empty()
public CompletableFuture<Collection<Instance>> requestTaskManagerInstances(Time timeout)
JobManagerGateway
requestTaskManagerInstances
in interface JobManagerGateway
timeout
- for the asynchronous operationpublic CompletableFuture<Optional<org.apache.flink.runtime.messages.JobManagerMessages.ClassloadingProps>> requestClassloadingProps(JobID jobId, Time timeout)
JobManagerGateway
requestClassloadingProps
in interface JobManagerGateway
jobId
- for which the class loading properties are requestedtimeout
- for this operationpublic CompletableFuture<MultipleJobsDetails> requestMultipleJobDetails(Time timeout)
RestfulGateway
requestMultipleJobDetails
in interface RestfulGateway
timeout
- for the asynchronous operationpublic CompletableFuture<AccessExecutionGraph> requestJob(JobID jobId, Time timeout)
RestfulGateway
AccessExecutionGraph
for the given jobId. If there is no such graph, then
the future is completed with a FlinkJobNotFoundException
.requestJob
in interface RestfulGateway
jobId
- identifying the job whose AccessExecutionGraph is requestedtimeout
- for the asynchronous operationFlinkJobNotFoundException
public CompletableFuture<JobResult> requestJobResult(JobID jobId, Time timeout)
RestfulGateway
JobResult
of a job specified by the given jobId.requestJobResult
in interface RestfulGateway
jobId
- identifying the job for which to retrieve the JobResult
.timeout
- for the asynchronous operationJobResult
once the job has finishedpublic CompletableFuture<ClusterOverview> requestClusterOverview(Time timeout)
RestfulGateway
requestClusterOverview
in interface RestfulGateway
timeout
- for the asynchronous operationpublic CompletableFuture<Collection<String>> requestMetricQueryServicePaths(Time timeout)
RestfulGateway
MetricQueryService
to query.requestMetricQueryServicePaths
in interface RestfulGateway
timeout
- for the asynchronous operationpublic CompletableFuture<Collection<Tuple2<ResourceID,String>>> requestTaskManagerMetricQueryServicePaths(Time timeout)
RestfulGateway
MetricQueryService
to query.requestTaskManagerMetricQueryServicePaths
in interface RestfulGateway
timeout
- for the asynchronous operationpublic CompletableFuture<JobIdsWithStatusOverview> requestJobsOverview(Time timeout)
JobManagerGateway
requestJobsOverview
in interface JobManagerGateway
timeout
- for the asynchronous operationpublic CompletableFuture<String> requestRestAddress(Time timeout)
RestfulGateway
RpcEndpoint
.requestRestAddress
in interface RestfulGateway
timeout
- for this operationCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.