Modifier and Type | Interface and Description |
---|---|
interface |
DispatcherGateway
Gateway for the Dispatcher component.
|
Modifier and Type | Class and Description |
---|---|
class |
Dispatcher
Base class for the Dispatcher component.
|
class |
MiniDispatcher
Mini Dispatcher which is instantiated as the dispatcher component by the
JobClusterEntrypoint . |
class |
StandaloneDispatcher
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobMasterGateway
JobMaster rpc gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
JobMaster
JobMaster implementation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ResourceManagerGateway
The
ResourceManager 's RPC gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
ResourceManager<WorkerType extends ResourceIDRetrievable>
ResourceManager implementation.
|
class |
StandaloneResourceManager
A standalone implementation of the resource manager.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveResourceManager<WorkerType extends ResourceIDRetrievable>
An active implementation of
ResourceManager . |
Modifier and Type | Method and Description |
---|---|
<F extends Serializable,C extends FencedRpcGateway<F>> |
RpcService.connect(String address,
F fencingToken,
Class<C> clazz)
Connect to a remote fenced rpc server under the provided address.
|
Modifier and Type | Class and Description |
---|---|
class |
FencedAkkaInvocationHandler<F extends Serializable>
Fenced extension of the
AkkaInvocationHandler . |
Modifier and Type | Method and Description |
---|---|
<F extends Serializable,C extends FencedRpcGateway<F>> |
AkkaRpcService.connect(String address,
F fencingToken,
Class<C> clazz) |
Modifier and Type | Class and Description |
---|---|
class |
RpcGatewayRetriever<F extends Serializable,T extends FencedRpcGateway<F>>
LeaderGatewayRetriever implementation using the RpcService . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.