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,
and the backlog length indicating how many non-event buffers are available in the
subpartition. |
InputChannelID |
Identifier for input channels.
|
InputGate |
An input gate consumes one or more partitions of a single produced intermediate result.
|
InputGate.InputWithData<INPUT,DATA> |
Simple pojo for INPUT, DATA and moreAvailable.
|
InputGateID |
Runtime identifier of a consumed
IntermediateResult . |
LocalInputChannel |
An input channel, which requests a local subpartition.
|
RemoteChannelStateChecker |
Handles the response of
PartitionProducerStateProvider . |
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.
|
SingleInputGateFactory |
Factory for
SingleInputGate to use in NettyShuffleEnvironment . |
UnionInputGate |
Input gate wrapper to union the input from multiple input gates.
|
Exception | Description |
---|---|
PartitionConnectionException |
Exception for failed partition requests due to connection failure
with unreachable producer.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.