OffsetCheckpoint

OffsetCheckpoint is…FIXME

OffsetCheckpoint is created when:

OffsetCheckpoint only takes the offset checkpoint file when created.

Note	The default name of the file is .checkpoint.

OffsetCheckpoint uses the internal version to maintain compatibility between checkpointing protocols. The current version is 0.

Map<TopicPartition, Long> read() throws IOException

read…FIXME

Note	`read` is used when: `GlobalStateManagerImpl` is requested to initialize `ProcessorStateManager` is created

void write(final Map<TopicPartition, Long> offsets) throws IOException

write…FIXME

Note	`write` is used when: `AbstractStateManager` is requested to reinitializeStateStoresForPartitions `GlobalStateManagerImpl` is requested to checkpoint `ProcessorStateManager` is requested to checkpoint

void delete() throws IOException

delete simply deletes the offset checkpoint file if exists.

Note	`delete` is used exclusively when `ProcessorStateManager` is created (with Exactly-Once Support (EOS) enabled).

results matching ""