Package 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 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.
        Returns:
        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.