Interface | Description |
---|---|
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.
|