Interface | Description |
---|---|
Checkpoint | |
CheckpointListener |
SystemConsumers that want to be notified about checkpoints for their SSPs and potentially modify them may
implement this interface.
|
CheckpointManager |
CheckpointManagers read and write
Checkpoint to some
implementation-specific location. |
CheckpointManagerFactory |
Build a
CheckpointManager . |
Class | Description |
---|---|
CheckpointId |
Checkpoint ID has the format: [currentTimeMillis, last 6 digits of nanotime], separated by a dash.
|
CheckpointV1 |
A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.
|
CheckpointV2 |
A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.
|