Tracks status of upstream channels while they recover.
CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input
CheckpointBarrierTracker keeps track of what checkpoint barriers have been received
from which input channels.
SingleCheckpointBarrierHandler is used for triggering checkpoint while reading the first
barrier and keeping track of the number of received barriers and consumed barriers.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.