| Interface | Description |
|---|---|
| CheckpointListener |
This interface should be implemented by SystemConsumers which want to be notified about checkpoint values
of the most recent checkpoint.
|
| CheckpointManager |
CheckpointManagers read and write
Checkpoint to some
implementation-specific location. |
| CheckpointManagerFactory |
Build a
CheckpointManager. |
| Class | Description |
|---|---|
| Checkpoint |
A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.
|