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.CheckpointImpl
asImpl()
For internal use.static Checkpoint
fromBytes(java.nio.ByteBuffer serializedCheckpoint)
Deserializes the checkpoint from its serialized from obtained from callingtoBytes()
.java.lang.String
getName()
Returns the name of the Checkpoint specified inReaderGroup.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 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.
-
-