Package org.apache.flink.runtime.taskexecutor.rpc
-
Class Summary Class Description RpcCheckpointResponder RpcGlobalAggregateManager RpcInputSplitProvider RpcKvStateRegistryListener KvStateRegistryListener
implementation for the new RPC service.RpcPartitionStateChecker RpcTaskOperatorEventGateway An OperatorEventSender that calls the RPC gatewayJobMasterOperatorEventGateway
to send the messages to the coordinator.