org.apache.flink.runtime.io.network.partition.consumer

Classes

• BufferManager
• BufferOrEvent
• EndOfChannelStateEvent
• IndexedInputGate
• InputChannel
• InputChannel.BufferAndAvailability
• InputChannelID
• InputGate
• InputGate.InputWithData
• InputGateID
• LocalInputChannel
• LocalRecoveredInputChannel
• RecoveredInputChannel
• RemoteChannelStateChecker
• RemoteInputChannel
• RemoteRecoveredInputChannel
• SingleInputGate
• SingleInputGateFactory
• SingleInputGateFactory.ChannelStatistics
• UnionInputGate

Exceptions

• PartitionConnectionException