Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.streaming.runtime.io.checkpointing |
Modifier and Type | Class and Description |
---|---|
class |
LocalInputChannel
An input channel, which requests a local subpartition.
|
class |
LocalRecoveredInputChannel
An input channel reads recovered state from previous unaligned checkpoint snapshots and then
converts into
LocalInputChannel finally. |
class |
RecoveredInputChannel
An input channel reads recovered state from previous unaligned checkpoint snapshots.
|
class |
RemoteInputChannel
An input channel, which requests a remote partition queue.
|
class |
RemoteRecoveredInputChannel
An input channel reads recovered state from previous unaligned checkpoint snapshots and then
converts into
RemoteInputChannel finally. |
Modifier and Type | Method and Description |
---|---|
protected InputChannel |
SingleInputGateFactory.createKnownInputChannel(SingleInputGate inputGate,
int index,
NettyShuffleDescriptor inputChannelDescriptor,
int consumedSubpartitionIndex,
SingleInputGateFactory.ChannelStatistics channelStatistics,
InputChannelMetrics metrics) |
InputChannel |
SingleInputGate.getChannel(int channelIndex) |
abstract InputChannel |
InputGate.getChannel(int channelIndex)
Returns the channel of this gate.
|
InputChannel |
UnionInputGate.getChannel(int channelIndex) |
InputChannel |
RecoveredInputChannel.toInputChannel() |
protected InputChannel |
RemoteRecoveredInputChannel.toInputChannelInternal() |
protected abstract InputChannel |
RecoveredInputChannel.toInputChannelInternal() |
protected InputChannel |
LocalRecoveredInputChannel.toInputChannelInternal() |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.SubpartitionInfo,InputChannel> |
SingleInputGate.getInputChannels() |
protected PrioritizedDeque<InputChannel> |
SingleInputGate.getInputChannelsWithData() |
Modifier and Type | Method and Description |
---|---|
void |
SingleInputGate.setInputChannels(InputChannel... channels) |
Constructor and Description |
---|
BufferManager(MemorySegmentProvider globalPool,
InputChannel inputChannel,
int numRequiredBuffers) |
Modifier and Type | Method and Description |
---|---|
InputChannel |
InputGateWithMetrics.getChannel(int channelIndex) |
Modifier and Type | Method and Description |
---|---|
InputChannel |
CheckpointedInputGate.getChannel(int channelIndex) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.