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

Interface Summary

Interface	Description
InputGate	An input gate consumes one or more partitions of a single produced intermediate result.
InputGateListener	Listener interface implemented by consumers of InputGate instances that want to be notified of availability of buffer or event instances.

Class Summary

Class	Description
BufferOrEvent	Either type for Buffer or AbstractEvent instances tagged with the channel index, from which they were received.
InputChannel	An input channel consumes a single ResultSubpartitionView.
InputChannel.BufferAndAvailability	A combination of a Buffer and a flag indicating availability of further buffers.
InputChannelID
InputGateMetrics	Collects metrics of an input gate.
LocalInputChannel	An input channel, which requests a local subpartition.
RemoteInputChannel	An input channel, which requests a remote partition queue.
SingleInputGate	An input gate consumes one or more partitions of a single produced intermediate result.
UnionInputGate	Input gate wrapper to union the input from multiple input gates.