Modifier and Type | Method and Description |
---|---|
protected ActorGateway |
CliFrontend.getJobManagerGateway(CommandLineOptions options)
Retrieves the
ActorGateway for the JobManager. |
Modifier and Type | Method and Description |
---|---|
ActorGateway |
ClusterClient.getJobManagerGateway()
Returns the
ActorGateway of the current job manager leader using
the LeaderRetrievalService . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ActorGateway> |
KvStateClientProxyImpl.getJobManagerFuture() |
Modifier and Type | Method and Description |
---|---|
void |
KvStateClientProxyImpl.updateJobManager(CompletableFuture<ActorGateway> leadingJobManager) |
Constructor and Description |
---|
AkkaJobManagerGateway(ActorGateway jobManagerGateway) |
Modifier and Type | Class and Description |
---|---|
class |
AkkaActorGateway
Concrete
ActorGateway implementation which uses Akka to communicate with remote actors. |
Modifier and Type | Method and Description |
---|---|
void |
AkkaActorGateway.forward(Object message,
ActorGateway sender)
Forwards a message.
|
void |
ActorGateway.forward(Object message,
ActorGateway sender)
Forwards a message.
|
void |
AkkaActorGateway.tell(Object message,
ActorGateway sender)
Sends a message asynchronously without a result with sender being the sender.
|
void |
ActorGateway.tell(Object message,
ActorGateway sender)
Sends a message asynchronously without a result with sender being the sender.
|
Modifier and Type | Method and Description |
---|---|
ActorGateway |
ActorTaskManagerGateway.getActorGateway() |
Constructor and Description |
---|
ActorTaskManagerGateway(ActorGateway actorGateway) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ActorGateway> |
KvStateClientProxy.getJobManagerFuture()
Retrieves a future containing the currently leading Job Manager.
|
Modifier and Type | Method and Description |
---|---|
void |
KvStateClientProxy.updateJobManager(CompletableFuture<ActorGateway> leadingJobManager)
Updates the active
Job Manager
in case of change. |
Constructor and Description |
---|
ActorGatewayCheckpointResponder(ActorGateway actorGateway) |
ActorGatewayKvStateRegistryListener(ActorGateway jobManager,
InetSocketAddress kvStateServerAddress) |
ActorGatewayPartitionProducerStateChecker(ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration timeout) |
ActorGatewayResultPartitionConsumableNotifier(scala.concurrent.ExecutionContext executionContext,
ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration jobManagerMessageTimeout) |
ActorGatewayTaskExecutionStateListener(ActorGateway actorGateway) |
ActorGatewayTaskManagerActions(ActorGateway actorGateway) |
TaskInputSplitProvider(ActorGateway jobManager,
JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionID,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
static ActorGateway |
LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalService leaderRetrievalService,
akka.actor.ActorSystem actorSystem,
scala.concurrent.duration.FiniteDuration timeout)
Retrieves the current leader gateway using the given
LeaderRetrievalService . |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<ActorGateway> |
LeaderRetrievalUtils.LeaderGatewayListener.getActorGatewayFuture() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.