Modifier and Type | Interface and Description |
---|---|
interface |
CheckpointCoordinatorGateway
RPC Gateway interface for messages to the CheckpointCoordinator.
|
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 | Class and Description |
---|---|
class |
MetricQueryService
The MetricQueryService creates a key-value representation of all metrics currently registered
with Flink when queried.
|
Modifier and Type | Class and Description |
---|---|
class |
RegisteredRpcConnection<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success,R extends RegistrationResponse.Rejection>
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,R extends RegistrationResponse.Rejection>
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 |
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 | 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 RpcGateway> |
RpcService.getSelfGateway(Class<C> selfGatewayType,
RpcServer rpcServer)
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 RpcGateway> |
AkkaRpcService.getSelfGateway(Class<C> selfGatewayType,
RpcServer rpcServer) |
<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.
|
class |
TaskExecutorGatewayDecoratorBase
A class that decorates/forwards calls to a
TaskExecutorGateway . |
Modifier and Type | Interface and Description |
---|---|
interface |
RestfulGateway
Gateway for restful endpoints.
|
Modifier and Type | Class and Description |
---|---|
class |
NonLeaderRetrievalRestfulGateway
* Gateway for restful endpoints without leader retrieval logic.
|
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 | Interface and Description |
---|---|
interface |
MetricQueryServiceGateway
MetricQueryService rpc gateway interface. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.