Interface | Description |
---|---|
BarrierAlignmentUtil.Cancellable |
A handle to a delayed action which can be cancelled.
|
BarrierAlignmentUtil.DelayableTimer |
It can register a task to be executed some time later.
|
UpstreamRecoveryTracker |
Tracks status of upstream channels while they recover.
|
Class | Description |
---|---|
BarrierAlignmentUtil |
Utility for barrier alignment.
|
CheckpointBarrierHandler |
The
CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input
channels. |
CheckpointBarrierTracker |
The
CheckpointBarrierTracker keeps track of what checkpoint barriers have been received
from which input channels. |
CheckpointedInputGate |
The
CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming CheckpointBarrier from the InputGate . |
InputProcessorUtil |
Utility for creating
CheckpointedInputGate based on checkpoint mode for StreamOneInputProcessor . |
SingleCheckpointBarrierHandler |
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–2022 The Apache Software Foundation. All rights reserved.