Modifier and Type | Method and Description |
---|---|
CheckpointBarrier |
CheckpointBarrier.asUnaligned() |
CheckpointBarrier |
CheckpointBarrier.withOptions(CheckpointOptions checkpointOptions) |
Modifier and Type | Method and Description |
---|---|
void |
IndexedInputGate.checkpointStarted(CheckpointBarrier barrier) |
void |
CheckpointableInput.checkpointStarted(CheckpointBarrier barrier) |
void |
LocalInputChannel.checkpointStarted(CheckpointBarrier barrier) |
void |
RemoteInputChannel.checkpointStarted(CheckpointBarrier barrier)
Spills all queued buffers on checkpoint start.
|
void |
RecoveredInputChannel.checkpointStarted(CheckpointBarrier barrier) |
void |
InputChannel.checkpointStarted(CheckpointBarrier barrier)
Called by task thread when checkpointing is started (e.g., any input channel received
barrier).
|
Modifier and Type | Method and Description |
---|---|
void |
StreamTaskSourceInput.checkpointStarted(CheckpointBarrier barrier)
This method is used with unaligned checkpoints to mark the arrival of a first
CheckpointBarrier . |
Modifier and Type | Method and Description |
---|---|
protected void |
SingleCheckpointBarrierHandler.markCheckpointAlignedAndTransformState(InputChannelInfo alignedChannel,
CheckpointBarrier barrier,
FunctionWithException<org.apache.flink.streaming.runtime.io.checkpointing.BarrierHandlerState,org.apache.flink.streaming.runtime.io.checkpointing.BarrierHandlerState,Exception> stateTransformer) |
protected void |
CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrier checkpointBarrier) |
void |
SingleCheckpointBarrierHandler.processBarrier(CheckpointBarrier barrier,
InputChannelInfo channelInfo,
boolean isRpcTriggered) |
void |
CheckpointBarrierTracker.processBarrier(CheckpointBarrier receivedBarrier,
InputChannelInfo channelInfo,
boolean isRpcTriggered) |
abstract void |
CheckpointBarrierHandler.processBarrier(CheckpointBarrier receivedBarrier,
InputChannelInfo channelInfo,
boolean isRpcTriggered) |
void |
SingleCheckpointBarrierHandler.processBarrierAnnouncement(CheckpointBarrier announcedBarrier,
int sequenceNumber,
InputChannelInfo channelInfo) |
void |
CheckpointBarrierTracker.processBarrierAnnouncement(CheckpointBarrier announcedBarrier,
int sequenceNumber,
InputChannelInfo channelInfo) |
abstract void |
CheckpointBarrierHandler.processBarrierAnnouncement(CheckpointBarrier announcedBarrier,
int sequenceNumber,
InputChannelInfo channelInfo) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.