Package org.apache.flink.runtime.rpc

Interface Summary

Interface	Description
FatalErrorHandler	Handler for fatal errors.
FencedRpcGateway<F extends Serializable>	Fenced RpcGateway.
MainThreadExecutable	Interface to execute Runnable and Callable in the main thread of the underlying RPC endpoint.
RpcGateway	Rpc gateway interface which has to be implemented by Rpc gateways.
RpcServer	Interface for self gateways.
RpcService	Interface for rpc services.
RpcSystem	This interface serves as a factory interface for RPC services, with some additional utilities that are reliant on implementation details of the RPC service.
RpcSystem.RpcServiceBuilder	Builder for RpcService.
RpcSystemLoader	A loader for an RpcSystem.
RpcSystemUtils	Utils that are dependent on the underlying RPC implementation.
StartStoppable	Interface to start and stop the processing of rpc calls in the rpc server.

Class Summary

Class	Description
CleanupOnCloseRpcSystem	An RpcSystem wrapper that cleans up resources after the RPC system has been closed.
FencedRpcEndpoint<F extends Serializable>	Base class for fenced RpcEndpoint.
MainThreadValidatorUtil	This utility exists to bridge between the visibility of the currentMainThread field in the RpcEndpoint.
RpcEndpoint	Base class for RPC endpoints.
RpcEndpoint.MainThreadExecutor	Executor which executes runnables in the main thread context.
RpcGatewayUtils	Utils for RpcGateway implementations.
RpcServiceUtils	These RPC utilities contain helper methods around RPC use.
RpcSystem.FixedThreadPoolExecutorConfiguration	Descriptor for creating a thread-pool with a fixed number of threads.
RpcSystem.ForkJoinExecutorConfiguration	Descriptor for creating a fork-join thread-pool.
RpcUtils	Utility functions for Flink's RPC implementation.

Enum Summary

Enum	Description
AddressResolution	Enum specifying whether address resolution should be tried.

Annotation Types Summary

Annotation Type	Description
Local	Marks an RPC invocation for only being supported as a local invocation.
RpcTimeout	Annotation for RpcGateway methods to specify an additional timeout parameter for the returned future to be completed.