Package io.pravega.client.stream
Interface Checkpoint
-
public interface Checkpoint
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description io.pravega.client.stream.impl.CheckpointImplasImpl()For internal use.static CheckpointfromBytes(java.nio.ByteBuffer serializedCheckpoint)Deserializes the checkpoint from its serialized from obtained from callingtoBytes().java.lang.StringgetName()Returns the name of the Checkpoint specified inReaderGroup.initiateCheckpoint(String, java.util.concurrent.ScheduledExecutorService).java.nio.ByteBuffertoBytes()Serializes the checkpoint to a compact byte array.
-
-
-
Method Detail
-
getName
java.lang.String getName()
Returns the name of the Checkpoint specified inReaderGroup.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.- Returns:
- A serialized version of this checkpoint.
-
fromBytes
static Checkpoint fromBytes(java.nio.ByteBuffer serializedCheckpoint)
Deserializes the checkpoint from its serialized from obtained from callingtoBytes().- Parameters:
serializedCheckpoint- A serialized checkpoint.- Returns:
- The checkpoint object.
-
-