Uses of Interface
org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler

Packages that use CheckpointBarrierHandler

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

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

Classes in org.apache.flink.streaming.runtime.io that implement CheckpointBarrierHandler

Modifier and Type	Class and Description
class	BarrierBuffer The barrier buffer is CheckpointBarrierHandler that blocks inputs with barriers until all inputs have received the barrier for a given checkpoint.
class	BarrierTracker The BarrierTracker keeps track of what checkpoint barriers have been received from which input channels.

Methods in org.apache.flink.streaming.runtime.io that return CheckpointBarrierHandler

Modifier and Type	Method and Description
static CheckpointBarrierHandler	InputProcessorUtil.createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.runtime.io.network.partition.consumer.InputGate inputGate, org.apache.flink.configuration.Configuration taskManagerConfig)