Package | Description |
---|---|
org.apache.flink.runtime.io.network.buffer | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.streaming.runtime.io |
Modifier and Type | Method and Description |
---|---|
void |
BufferReceivedListener.notifyBarrierReceived(CheckpointBarrier barrier,
InputChannelInfo channelInfo)
Invoked when an
InputChannel
receives a buffer with a CheckpointBarrier . |
Modifier and Type | Method and Description |
---|---|
protected CheckpointBarrier |
InputChannel.parseCheckpointBarrierOrNull(Buffer buffer)
Parses the buffer as an event and returns the
CheckpointBarrier if the event is
indeed a barrier or returns null in all other cases. |
Modifier and Type | Method and Description |
---|---|
protected void |
CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrier checkpointBarrier,
long alignmentDurationNanos) |
abstract void |
CheckpointBarrierHandler.processBarrier(CheckpointBarrier receivedBarrier,
InputChannelInfo channelInfo) |
void |
CheckpointBarrierTracker.processBarrier(CheckpointBarrier receivedBarrier,
InputChannelInfo channelInfo) |
void |
CheckpointBarrierUnaligner.processBarrier(CheckpointBarrier receivedBarrier,
InputChannelInfo channelInfo)
We still need to trigger checkpoint via
ThreadSafeUnaligner#notifyBarrierReceived(CheckpointBarrier, InputChannelInfo) while reading
the first barrier from one channel, because this might happen earlier than the previous async
trigger via mailbox by netty thread. |
void |
CheckpointBarrierAligner.processBarrier(CheckpointBarrier receivedBarrier,
InputChannelInfo channelInfo) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.