Modifier and Type | Class and Description |
---|---|
class |
MesosResourceManager
The Mesos implementation of the resource manager.
|
Modifier and Type | Class and Description |
---|---|
class |
AkkaJobManagerGateway
Implementation of the
JobManagerGateway for old JobManager code based
on Akka actors and the ActorGateway . |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckpointCoordinatorGateway |
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 |
JobManagerGateway
Public JobManager gateway.
|
interface |
JobMasterGateway
JobMaster rpc gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
JobMaster
JobMaster implementation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SlotPoolGateway
The gateway for calls on the
SlotPool . |
Modifier and Type | Class and Description |
---|---|
class |
SlotPool
The slot pool serves slot request issued by
ExecutionGraph . |
Modifier and Type | Class and Description |
---|---|
class |
RegisteredRpcConnection<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success>
This utility class implements the basis of RPC connecting from one component to another component,
for example the RPC connection from TaskExecutor to ResourceManager.
|
class |
RetryingRegistration<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success>
This utility class implements the basis of registering one component at another component,
for example registering the TaskExecutor at the ResourceManager.
|
Modifier and Type | Interface and Description |
---|---|
interface |
InfoMessageListenerRpcGateway
A gateway to listen for info messages from
ResourceManager |
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 | Interface and Description |
---|---|
interface |
FencedRpcGateway<F extends Serializable>
Fenced
RpcGateway . |
interface |
RpcServer
Interface for self gateways.
|
Modifier and Type | Class and Description |
---|---|
class |
FencedRpcEndpoint<F extends Serializable>
Base class for fenced
RpcEndpoint . |
class |
RpcEndpoint
Base class for RPC endpoints.
|
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
RpcService.connect(String address,
Class<C> clazz)
Connect to a remote rpc server under the provided address.
|
<C extends RpcGateway> |
RpcEndpoint.getSelfGateway(Class<C> selfGatewayType)
Returns a self gateway of the specified type which can be used to issue asynchronous
calls against the RpcEndpoint.
|
<C extends RpcEndpoint & RpcGateway> |
RpcService.startServer(C rpcEndpoint)
Start a rpc server which forwards the remote procedure calls to the provided rpc endpoint.
|
Modifier and Type | Method and Description |
---|---|
static Set<Class<? extends RpcGateway>> |
RpcUtils.extractImplementedRpcGateways(Class<?> clazz)
Extracts all
RpcGateway interfaces implemented by the given clazz. |
Modifier and Type | Class and Description |
---|---|
class |
FencedAkkaRpcActor<F extends Serializable,T extends FencedRpcEndpoint<F> & RpcGateway>
Fenced extension of the
AkkaRpcActor . |
Modifier and Type | Class and Description |
---|---|
class |
FencedAkkaInvocationHandler<F extends Serializable>
Fenced extension of the
AkkaInvocationHandler . |
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
AkkaRpcService.connect(String address,
Class<C> clazz) |
<C extends RpcEndpoint & RpcGateway> |
AkkaRpcService.startServer(C rpcEndpoint) |
Modifier and Type | Interface and Description |
---|---|
interface |
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
TaskExecutor
TaskExecutor implementation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RestfulGateway
Gateway for restful endpoints.
|
Modifier and Type | Interface and Description |
---|---|
interface |
GatewayRetriever<T extends RpcGateway>
Generic retriever interface for
RpcGateway . |
class |
LeaderGatewayRetriever<T extends RpcGateway>
Retrieves and stores the leading
RpcGateway . |
Modifier and Type | Class and Description |
---|---|
class |
YarnResourceManager
The yarn implementation of the resource manager.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.