Uses of Class
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler

Packages that use SingleCheckpointBarrierHandler

Package	Description
org.apache.flink.streaming.runtime.io.checkpointing

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

Methods in org.apache.flink.streaming.runtime.io.checkpointing that return SingleCheckpointBarrierHandler

Modifier and Type	Method	Description
static SingleCheckpointBarrierHandler	SingleCheckpointBarrierHandler.aligned(String taskName, org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask toNotifyOnCheckpoint, org.apache.flink.util.clock.Clock clock, int numOpenChannels, BarrierAlignmentUtil.DelayableTimer registerTimer, boolean enableCheckpointAfterTasksFinished, org.apache.flink.runtime.io.network.partition.consumer.CheckpointableInput... inputs)
static SingleCheckpointBarrierHandler	SingleCheckpointBarrierHandler.alternating(String taskName, org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask toNotifyOnCheckpoint, SubtaskCheckpointCoordinator checkpointCoordinator, org.apache.flink.util.clock.Clock clock, int numOpenChannels, BarrierAlignmentUtil.DelayableTimer registerTimer, boolean enableCheckpointAfterTasksFinished, org.apache.flink.runtime.io.network.partition.consumer.CheckpointableInput... inputs)
static SingleCheckpointBarrierHandler	SingleCheckpointBarrierHandler.createUnalignedCheckpointBarrierHandler(SubtaskCheckpointCoordinator checkpointCoordinator, String taskName, org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask toNotifyOnCheckpoint, org.apache.flink.util.clock.Clock clock, boolean enableCheckpointsAfterTasksFinish, org.apache.flink.runtime.io.network.partition.consumer.CheckpointableInput... inputs)
static SingleCheckpointBarrierHandler	SingleCheckpointBarrierHandler.unaligned(String taskName, org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask toNotifyOnCheckpoint, SubtaskCheckpointCoordinator checkpointCoordinator, org.apache.flink.util.clock.Clock clock, int numOpenChannels, BarrierAlignmentUtil.DelayableTimer registerTimer, boolean enableCheckpointAfterTasksFinished, org.apache.flink.runtime.io.network.partition.consumer.CheckpointableInput... inputs)