org.apache.samza.checkpoint

Interface Checkpoint

All Known Implementing Classes:

CheckpointV1, CheckpointV2

public interface Checkpoint

Method Summary

Modifier and Type	Method and Description
java.util.Map<SystemStreamPartition,java.lang.String>	getOffsets() Gets a unmodifiable view of the last processed offsets for SystemStreamPartitions.
short	getVersion() Gets the version number of the Checkpoint

Method Detail

getVersion

short getVersion()

Gets the version number of the Checkpoint

Returns:

Short indicating the version number

getOffsets

java.util.Map<SystemStreamPartition,java.lang.String> getOffsets()

Gets a unmodifiable view of the last processed offsets for SystemStreamPartitions. The returned value differs based on the Checkpoint version:

1. For CheckpointV1, returns the input SystemStreamPartition offsets, as well as the latest KafkaStateChangelogOffset for any store changelog SystemStreamPartition
2. For CheckpointV2 returns the input offsets only.

Returns:

a unmodifiable view of last processed offsets for SystemStreamPartitions.