Package | Description |
---|---|
org.apache.flink.runtime.io.network.api | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.streaming.runtime.io |
Modifier and Type | Method and Description |
---|---|
CheckpointBarrier |
CheckpointBarrier.withOptions(CheckpointOptions checkpointOptions) |
Modifier and Type | Method and Description |
---|---|
void |
IndexedInputGate.checkpointStarted(CheckpointBarrier barrier) |
void |
InputChannel.checkpointStarted(CheckpointBarrier barrier)
Called by task thread when checkpointing is started (e.g., any input channel received
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) |
Modifier and Type | Method and Description |
---|---|
void |
AlternatingController.barrierReceived(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
void |
UnalignedController.barrierReceived(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
void |
AlignedController.barrierReceived(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
void |
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked per every received
CheckpointBarrier . |
void |
StreamTaskSourceInput.checkpointStarted(CheckpointBarrier barrier)
This method is used with unaligned checkpoints to mark the arrival of a first
CheckpointBarrier . |
protected void |
CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrier 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) |
boolean |
AlternatingController.postProcessLastBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
UnalignedController.postProcessLastBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
AlignedController.postProcessLastBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
CheckpointBarrierBehaviourController.postProcessLastBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked once per checkpoint, after the last invocation of
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint. |
boolean |
AlternatingController.preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
UnalignedController.preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
AlignedController.preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
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) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.