95-260-058-源码-检查点-CheckpointBarrierHandler

2.概述

flink 的 CheckpointBarrierHandler，CheckpointBarrierHandler 会根据 flink 的两种工作模式 —— EXACTLY_ONCE 和 AT_LEAST_ONCE 选取不同的实现类，CheckpointBarrierHandler 用于通知 StreamTask 检查点的完成和取消，StreamTask 再通过 OperatorChain 传递事件给所有的操作符（后续文章会讲解）

3.CheckpointBarrierHandler

CheckpointBarrierHandler 是一个接口，BarrierBuffer 和 BarrierTracker 是两个实现类，BarrierBuffer 用于 EXACTLY_ONCE 模式，BarrierTracker 用于 AT_LEAST_ONCE 模式

public abstract