Uses of Class
org.apache.flink.runtime.checkpoint.channel.InputChannelInfo

Packages that use InputChannelInfo

Package	Description
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.state
org.apache.flink.runtime.taskmanager
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.checkpointing

Uses of InputChannelInfo in org.apache.flink.runtime.checkpoint.channel

Methods in org.apache.flink.runtime.checkpoint.channel with parameters of type InputChannelInfo

Modifier and Type	Method and Description
void	ChannelStateWriterImpl.addInputData(long checkpointId, InputChannelInfo info, int startSeqNum, CloseableIterator<Buffer> iterator)
void	ChannelStateWriter.addInputData(long checkpointId, InputChannelInfo info, int startSeqNum, CloseableIterator<Buffer> data) Add in-flight buffers from the InputChannel.
void	ChannelStateWriter.NoOpChannelStateWriter.addInputData(long checkpointId, InputChannelInfo info, int startSeqNum, CloseableIterator<Buffer> data)

Uses of InputChannelInfo in org.apache.flink.runtime.io.network.partition.consumer

Fields in org.apache.flink.runtime.io.network.partition.consumer declared as InputChannelInfo

Modifier and Type	Field and Description
protected InputChannelInfo	InputChannel.channelInfo The info of the input channel to identify it globally within a task.

Methods in org.apache.flink.runtime.io.network.partition.consumer that return InputChannelInfo

Modifier and Type	Method and Description
InputChannelInfo	InputChannel.getChannelInfo() Returns the info of this channel, which uniquely identifies the channel in respect to its operator instance.
InputChannelInfo	BufferOrEvent.getChannelInfo()

Methods in org.apache.flink.runtime.io.network.partition.consumer that return types with arguments of type InputChannelInfo

Modifier and Type	Method and Description
List<InputChannelInfo>	CheckpointableInput.getChannelInfos()
List<InputChannelInfo>	InputGate.getChannelInfos() Returns the channel infos of this gate.

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type InputChannelInfo

Modifier and Type	Method and Description
void	IndexedInputGate.blockConsumption(InputChannelInfo channelInfo)
void	CheckpointableInput.blockConsumption(InputChannelInfo channelInfo)
void	SingleInputGate.resumeConsumption(InputChannelInfo channelInfo)
void	CheckpointableInput.resumeConsumption(InputChannelInfo channelInfo)
void	UnionInputGate.resumeConsumption(InputChannelInfo channelInfo)
abstract void	InputGate.resumeConsumption(InputChannelInfo channelInfo)
void	BufferOrEvent.setChannelInfo(InputChannelInfo channelInfo)

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type InputChannelInfo

Constructor and Description
BufferOrEvent(AbstractEvent event, boolean hasPriority, InputChannelInfo channelInfo, boolean moreAvailable, int size, boolean morePriorityEvents)
BufferOrEvent(AbstractEvent event, InputChannelInfo channelInfo)
BufferOrEvent(Buffer buffer, InputChannelInfo channelInfo)
BufferOrEvent(Buffer buffer, InputChannelInfo channelInfo, boolean moreAvailable, boolean morePriorityEvents)

Uses of InputChannelInfo in org.apache.flink.runtime.state

Constructors in org.apache.flink.runtime.state with parameters of type InputChannelInfo

Constructor and Description
InputChannelStateHandle(InputChannelInfo info, StreamStateHandle delegate, List<Long> offset)
InputChannelStateHandle(int subtaskIndex, InputChannelInfo info, StreamStateHandle delegate, AbstractChannelStateHandle.StateContentMetaInfo contentMetaInfo)
InputChannelStateHandle(int subtaskIndex, InputChannelInfo info, StreamStateHandle delegate, List<Long> offset, long size)

Uses of InputChannelInfo in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager with parameters of type InputChannelInfo

Modifier and Type	Method and Description
void	InputGateWithMetrics.resumeConsumption(InputChannelInfo channelInfo)

Uses of InputChannelInfo in org.apache.flink.streaming.runtime.io

Methods in org.apache.flink.streaming.runtime.io that return types with arguments of type InputChannelInfo

Modifier and Type	Method and Description
List<InputChannelInfo>	StreamTaskSourceInput.getChannelInfos()

Methods in org.apache.flink.streaming.runtime.io with parameters of type InputChannelInfo

Modifier and Type	Method and Description
void	StreamTaskSourceInput.blockConsumption(InputChannelInfo channelInfo)
void	StreamTaskSourceInput.resumeConsumption(InputChannelInfo channelInfo)

Uses of InputChannelInfo in org.apache.flink.streaming.runtime.io.checkpointing

Methods in org.apache.flink.streaming.runtime.io.checkpointing that return types with arguments of type InputChannelInfo

Modifier and Type	Method and Description
Collection<InputChannelInfo>	AlignedController.getBlockedChannels()
List<InputChannelInfo>	CheckpointedInputGate.getChannelInfos()
Map<InputChannelInfo,Integer>	AlignedController.getSequenceNumberInAnnouncedChannels()

Methods in org.apache.flink.streaming.runtime.io.checkpointing with parameters of type InputChannelInfo

Modifier and Type	Method and Description
void	AlternatingController.barrierAnnouncement(InputChannelInfo channelInfo, CheckpointBarrier announcedBarrier, int sequenceNumber)
void	UnalignedController.barrierAnnouncement(InputChannelInfo channelInfo, CheckpointBarrier announcedBarrier, int sequenceNumber)
void	AlignedController.barrierAnnouncement(InputChannelInfo channelInfo, CheckpointBarrier announcedBarrier, int sequenceNumber)
void	CheckpointBarrierBehaviourController.barrierAnnouncement(InputChannelInfo channelInfo, CheckpointBarrier announcedBarrier, int sequenceNumber) Invoked per every CheckpointBarrier announcement.
Optional<CheckpointBarrier>	AlternatingController.barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	UnalignedController.barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	AlignedController.barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier) Invoked per every received CheckpointBarrier.
void	AlternatingController.obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
void	UnalignedController.obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
void	AlignedController.obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
void	CheckpointBarrierBehaviourController.obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	AlternatingController.postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	UnalignedController.postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	AlignedController.postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	CheckpointBarrierBehaviourController.postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier) Invoked once per checkpoint, after the last invocation of CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint.
Optional<CheckpointBarrier>	AlternatingController.preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	UnalignedController.preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	AlignedController.preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
Optional<CheckpointBarrier>	CheckpointBarrierBehaviourController.preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier) Invoked once per checkpoint, before the first invocation of CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint.
abstract void	CheckpointBarrierHandler.processBarrier(CheckpointBarrier receivedBarrier, InputChannelInfo channelInfo)
void	CheckpointBarrierTracker.processBarrier(CheckpointBarrier receivedBarrier, InputChannelInfo channelInfo)
void	SingleCheckpointBarrierHandler.processBarrier(CheckpointBarrier barrier, InputChannelInfo channelInfo)
abstract void	CheckpointBarrierHandler.processBarrierAnnouncement(CheckpointBarrier announcedBarrier, int sequenceNumber, InputChannelInfo channelInfo)
void	CheckpointBarrierTracker.processBarrierAnnouncement(CheckpointBarrier announcedBarrier, int sequenceNumber, InputChannelInfo channelInfo)
void	SingleCheckpointBarrierHandler.processBarrierAnnouncement(CheckpointBarrier announcedBarrier, int sequenceNumber, InputChannelInfo channelInfo)