Modifier and Type | Class and Description |
---|---|
class |
JobAttachmentClientActor
Actor which handles Job attachment process and provides Job updates until completion.
|
class |
JobClientActor
Actor which constitutes the bridge between the non-actor code and the JobManager.
|
class |
JobSubmissionClientActor
Actor which handles Job submission process and provides Job updates until completion.
|
Modifier and Type | Method and Description |
---|---|
void |
StandaloneLeaderRetrievalService.start(LeaderRetrievalListener listener) |
void |
ZooKeeperLeaderRetrievalService.start(LeaderRetrievalListener listener) |
void |
SettableLeaderRetrievalService.start(LeaderRetrievalListener listener) |
void |
LeaderRetrievalService.start(LeaderRetrievalListener listener)
Starts the leader retrieval service with the given listener to listen for new leaders.
|
Modifier and Type | Class and Description |
---|---|
class |
OneTimeLeaderListenerFuture
A leader listener that exposes a future for the first leader notification.
|
Modifier and Type | Class and Description |
---|---|
static class |
ConnectionUtils.LeaderConnectingAddressListener
A
LeaderRetrievalListener that allows retrieving an InetAddress for the current leader. |
Modifier and Type | Class and Description |
---|---|
static class |
LeaderRetrievalUtils.LeaderConnectionInfoListener
Helper class which is used by the retrieveLeaderConnectionInfo method to retrieve the
leader's akka URL and the current leader session ID.
|
static class |
LeaderRetrievalUtils.LeaderGatewayListener
Helper class which is used by the retrieveLeaderGateway method as the
LeaderRetrievalListener . |
Modifier and Type | Class and Description |
---|---|
class |
LeaderGatewayRetriever<T extends RpcGateway>
Retrieves and stores the leading
RpcGateway . |
class |
LeaderRetriever
Retrieves and stores the current leader address.
|
Modifier and Type | Class and Description |
---|---|
class |
AkkaJobManagerRetriever
LeaderGatewayRetriever implementation for Akka based JobManagers. |
class |
RpcGatewayRetriever<F extends Serializable,T extends FencedRpcGateway<F>>
LeaderGatewayRetriever implementation using the RpcService . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.