Package com.linkedin.venice.pubsub.api

Interface PubSubPosition

All Superinterfaces:
Measurable
All Known Implementing Classes:
ApacheKafkaOffsetPosition, InMemoryPubSubPosition
public interface PubSubPosition extends Measurable
Represents a position of a message in a partition of a topic.

  • Method Details

    • comparePosition

      int comparePosition(PubSubPosition other)
      Parameters:
      other - the other position to compare to
      Returns:
      returns 0 if the positions are equal, -1 if this position is less than the other position, and 1 if this position is greater than the other position

    • diff

      long diff(PubSubPosition other)
      Returns:
      the difference between this position and the other position

    • equals

      boolean equals(Object obj)
      Overrides:
      equals in class Object

    • hashCode

      int hashCode()
      Overrides:
      hashCode in class Object

    • getNumericOffset

      long getNumericOffset()

    • getPositionWireFormat

      PubSubPositionWireFormat getPositionWireFormat()
      Position wrapper is used to wrap the position type and the position value. This is used to serialize and deserialize the position object when sending and receiving it over the wire.
      Returns:
      the position wrapper

    • getPositionFromWireFormat

      static PubSubPosition getPositionFromWireFormat(PubSubPositionWireFormat positionWireFormat)