Class and Description |
---|
CheckpointedInputGate
The
CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming CheckpointBarrier from the InputGate . |
Class and Description |
---|
CheckpointBarrierHandler
The
CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input
channels. |
CheckpointedInputGate
The
CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming CheckpointBarrier from the InputGate . |
SingleCheckpointBarrierHandler
SingleCheckpointBarrierHandler is used for triggering checkpoint while reading the first
barrier and keeping track of the number of received barriers and consumed barriers. |
UpstreamRecoveryTracker
Tracks status of upstream channels while they recover.
|
Class and Description |
---|
CheckpointedInputGate
The
CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming CheckpointBarrier from the InputGate . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.