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

接口

• UpstreamRecoveryTracker

类

• CheckpointBarrierHandler
• CheckpointBarrierTracker
• CheckpointedInputGate
• InputProcessorUtil
• SingleCheckpointBarrierHandler