All Classes

Class	Description
ActorSystemBootstrapTools	Tools for starting the Actor Systems used to run the JobManager and TaskManager actors.
ActorSystemScheduledExecutorAdapter	Adapter to use a ActorSystem as a ScheduledExecutor.
ControlMessages	Control messages for the PekkoRpcActor.
CustomSSLEngineProvider	Extension of the ConfigSSLEngineProvider to use a FingerprintTrustManagerFactory.
DeadLettersActor	Actor which listens to DeadLetter and responds with a failure if the message was a RPC.
EscalatingSupervisorStrategy	Escalating supervisor strategy.
FencedPekkoInvocationHandler<F extends Serializable>	Fenced extension of the PekkoInvocationHandler.
FencedPekkoRpcActor<F extends Serializable,T extends org.apache.flink.runtime.rpc.FencedRpcEndpoint<F> & org.apache.flink.runtime.rpc.RpcGateway>	Fenced extension of the PekkoRpcActor.
PekkoRpcService	Pekko based RpcService implementation.
PekkoRpcServiceConfiguration	Configuration for the PekkoRpcService.
PekkoRpcServiceUtils	These RPC utilities contain helper methods around RPC use, such as starting an RPC service, or constructing RPC addresses.
PekkoRpcServiceUtils.Protocol	Whether to use TCP or encrypted TCP for Pekko.
PekkoRpcSystem	RpcSystem implementation based on Pekko.
PrioritySettingThreadFactory	Wrapper around a ThreadFactory that configures the thread priority.
PriorityThreadsDispatcher	Pekko dispatcher threads creates threads with configurable priority.
RemoteAddressExtension	ActorSystem Extension used to obtain the Address on which the given ActorSystem is listening.
RemoteAddressExtension.RemoteAddressExtensionImpl	Actual Extension implementation.
RobustActorSystem	ActorSystemImpl} which has a configurable Thread.UncaughtExceptionHandler.
RpcInvalidStateException	Exception which indicates an invalid state.
ScalaFutureUtils	Utilities to convert Scala types into Java types.
UnknownMessageException	Exception which indicates that the PekkoRpcActor has received an unknown message type.