io.pravega.client.stream

Interface Position

public interface Position

A position in a stream. Used to indicate where a reader died. See ReaderGroup.readerOffline(String, Position) Note that this is serializable so that it can be written to an external datastore.

Method Summary

Modifier and Type	Method and Description
io.pravega.client.stream.impl.PositionInternal	asImpl() Used internally.
static Position	fromBytes(java.nio.ByteBuffer serializedPosition) Deserializes the position from its serialized from obtained from calling toBytes().
java.nio.ByteBuffer	toBytes() Serializes the position to a compact byte array.

Method Detail

asImpl

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

Used internally. Do not call.

Returns:

Implementation of position object interface

toBytes

java.nio.ByteBuffer toBytes()

Serializes the position to a compact byte array.

fromBytes

static Position fromBytes(java.nio.ByteBuffer serializedPosition)

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

Parameters:

serializedPosition - A serialized position.

Returns:

The position object.