io.pravega.client.stream

Interface Checkpoint

public interface Checkpoint

Method Summary

Modifier and Type	Method and Description
io.pravega.client.stream.impl.CheckpointImpl	asImpl() For internal use.
static Checkpoint	fromBytes(java.nio.ByteBuffer serializedCheckpoint) Deserializes the checkpoint from its serialized from obtained from calling toBytes().
java.lang.String	getName() Returns the name of the Checkpoint specified in ReaderGroup.initiateCheckpoint(String, java.util.concurrent.ScheduledExecutorService).
java.nio.ByteBuffer	toBytes() Serializes the checkpoint to a compact byte array.

Method Detail

getName

java.lang.String getName()

Returns the name of the Checkpoint specified in ReaderGroup.initiateCheckpoint(String, java.util.concurrent.ScheduledExecutorService).

Returns:

The checkpoint name;

asImpl

io.pravega.client.stream.impl.CheckpointImpl asImpl()

For internal use. Do not call.

Returns:

This

toBytes

java.nio.ByteBuffer toBytes()

Serializes the checkpoint to a compact byte array.

fromBytes

static Checkpoint fromBytes(java.nio.ByteBuffer serializedCheckpoint)

Deserializes the checkpoint from its serialized from obtained from calling toBytes().

Parameters:

serializedCheckpoint - A serialized checkpoint.

Returns:

The checkpoint object.