Class and Description |
---|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
IndexedInputGate
An
InputGate with a specific index. |
Class and Description |
---|
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.
|
InputGateID
Runtime identifier of a consumed
IntermediateResult . |
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.
|
Class and Description |
---|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
ChannelStatePersister
Helper class for persisting channel state via
ChannelStateWriter . |
Class and Description |
---|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
SingleInputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
RemoteInputChannel
An input channel, which requests a remote partition queue.
|
Class and Description |
---|
BufferManager
The general buffer manager used by
InputChannel to request/recycle exclusive or floating
buffers. |
BufferOrEvent
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
CheckpointableInput
Input, with just basic methods for blocking and resuming consumption.
|
EndOfChannelStateEvent
Marks the end of recovered state of
RecoveredInputChannel of this subtask or ResultSubpartition on the
upstream. |
IndexedInputGate
An
InputGate with a specific index. |
InputChannel
An input channel consumes a single
ResultSubpartitionView . |
InputChannelID
Identifier for input channels.
|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
RecoveredInputChannel
An input channel reads recovered state from previous unaligned checkpoint snapshots.
|
SingleInputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
SingleInputGateFactory.ChannelStatistics
Statistics of input channels.
|
Class and Description |
---|
IndexedInputGate
An
InputGate with a specific index. |
Class and Description |
---|
BufferOrEvent
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
CheckpointableInput
Input, with just basic methods for blocking and resuming consumption.
|
IndexedInputGate
An
InputGate with a specific index. |
InputChannel
An input channel consumes a single
ResultSubpartitionView . |
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
IndexedInputGate
An
InputGate with a specific index. |
Class and Description |
---|
BufferOrEvent
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
CheckpointableInput
Input, with just basic methods for blocking and resuming consumption.
|
IndexedInputGate
An
InputGate with a specific index. |
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
BufferOrEvent
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
CheckpointableInput
Input, with just basic methods for blocking and resuming consumption.
|
InputChannel
An input channel consumes a single
ResultSubpartitionView . |
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
BufferOrEvent
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
Class and Description |
---|
CheckpointableInput
Input, with just basic methods for blocking and resuming consumption.
|
IndexedInputGate
An
InputGate with a specific index. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.