Modifier and Type | Method and Description |
---|---|
ActorGateway |
ClusterClient.getJobManagerGateway()
Returns the
ActorGateway of the current job manager leader using
the LeaderRetrievalService . |
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) |
Constructor and Description |
---|
ActorGatewayCheckpointResponder(ActorGateway actorGateway) |
ActorGatewayKvStateLocationOracle(ActorGateway jobManagerActorGateway,
Time timeout) |
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–2019 The Apache Software Foundation. All rights reserved.