Class | Description |
---|---|
RpcCheckpointResponder | |
RpcGlobalAggregateManager | |
RpcInputSplitProvider | |
RpcKvStateRegistryListener |
KvStateRegistryListener implementation for the new RPC service. |
RpcPartitionStateChecker | |
RpcResultPartitionConsumableNotifier | |
RpcTaskOperatorEventGateway |
An OperatorEventSender that calls the RPC gateway
JobMasterOperatorEventGateway to send
the messages to the coordinator. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.