org.apache.samza.checkpoint

Interface CheckpointManager

public interface CheckpointManager

CheckpointManagers read and write Checkpoint to some implementation-specific location.

Method Summary

Methods

Modifier and Type	Method and Description
Checkpoint	readLastCheckpoint(Partition partition) Returns the last recorded checkpoint for a specified Samza stream partition.
void	register(Partition partition) Registers this manager to write checkpoints of a specific Samza stream partition.
void	start()
void	stop()
void	writeCheckpoint(Partition partition, Checkpoint checkpoint) Writes a checkpoint based on the current state of a Samza stream partition.

Method Detail

start

void start()

register

void register(Partition partition)

Registers this manager to write checkpoints of a specific Samza stream partition.

Parameters:

partition - Specific Samza stream partition of which to write checkpoints for.

writeCheckpoint

void writeCheckpoint(Partition partition,
                   Checkpoint checkpoint)

Writes a checkpoint based on the current state of a Samza stream partition.

Parameters:

partition - Specific Samza stream partition of which to write a checkpoint of.

checkpoint - Reference to a Checkpoint object to store offset data in.

readLastCheckpoint

Checkpoint readLastCheckpoint(Partition partition)

Returns the last recorded checkpoint for a specified Samza stream partition.

Parameters:

partition - Specific Samza stream partition for which to get the last checkpoint of.

Returns:

A Checkpoint object with the recorded offset data of the specified partition.

stop

void stop()