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 asImpl()
        Used internally. Do not call.
        Implementation of position object interface
      • toBytes

        java.nio.ByteBuffer toBytes()
        Serializes the position to a compact byte array.
        compact byte array
      • fromBytes

        static Position fromBytes​(java.nio.ByteBuffer serializedPosition)
        Deserializes the position from its serialized from obtained from calling toBytes().
        serializedPosition - A serialized position.
        The position object.