public interface CheckpointListener
Modifier and Type | Method and Description |
---|---|
default void |
afterCheckpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
Called after writing the checkpoint for each Task in the Container processing SSPs on this system.
|
default java.util.Map<SystemStreamPartition,java.lang.String> |
beforeCheckpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
Called before writing the checkpoint for each Task in the Container processing SSPs on this system.
|
default void |
onCheckpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
Deprecated.
|
default java.util.Map<SystemStreamPartition,java.lang.String> beforeCheckpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
offsets
- offsets about to be checkpointed.default void afterCheckpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
offsets
- offsets that were checkpointed.@Deprecated default void onCheckpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
afterCheckpoint(Map)
instead.offsets
- offsets that were checkpointed.