Package com.tangosol.net.topic

Class Publisher.OrderByValue<V>

java.lang.Object
com.tangosol.net.topic.Publisher.OrderBy<V>
com.tangosol.net.topic.Publisher.OrderByValue<V>
Type Parameters:
V - the value type
All Implemented Interfaces:
ExternalizableLite, PortableObject, Publisher.Option<V>, Serializable
Direct Known Subclasses:
Publisher.OrderByRoundRobin
Enclosing interface:
Publisher<V>
public static class Publisher.OrderByValue<V> extends Publisher.OrderBy<V>
Publisher.OrderBy option which computes the unit-of-order based on applying constructor's orderIdFunction parameter on sent value.
See Also:

  • Field Details

    • m_orderIdFunction

      protected ToIntFunction<? super V> m_orderIdFunction
      A function used to compute the unit-of-order from the value type V.

  • Constructor Details

    • OrderByValue

      public OrderByValue()

    • OrderByValue

      protected OrderByValue(ToIntFunction<? super V> orderIdFunction)

  • Method Details

    • getOrderId

      public int getOrderId(V value)
      Description copied from class: Publisher.OrderBy
      Return unit-of-order id.
      Specified by:
      getOrderId in class Publisher.OrderBy<V>
      Returns:
      the unit-of-order id

    • readExternal

      public void readExternal(DataInput in) throws IOException
      Description copied from interface: ExternalizableLite
      Restore the contents of this object by loading the object's state from the passed DataInput object.
      Parameters:
      in - the DataInput stream to read data from in order to restore the state of this object
      Throws:
      IOException - if an I/O exception occurs

    • writeExternal

      public void writeExternal(DataOutput out) throws IOException
      Description copied from interface: ExternalizableLite
      Save the contents of this object by storing the object's state into the passed DataOutput object.
      Parameters:
      out - the DataOutput stream to write the state of this object to
      Throws:
      IOException - if an I/O exception occurs

    • readExternal

      public void readExternal(PofReader in) throws IOException
      Description copied from interface: PortableObject
      Restore the contents of a user type instance by reading its state using the specified PofReader object.
      Parameters:
      in - the PofReader from which to read the object's state
      Throws:
      IOException - if an I/O error occurs

    • writeExternal

      public void writeExternal(PofWriter out) throws IOException
      Description copied from interface: PortableObject
      Save the contents of a POF user type instance by writing its state using the specified PofWriter object.
      Parameters:
      out - the PofWriter to which to write the object's state
      Throws:
      IOException - if an I/O error occurs

    • toString

      public String toString()
      Overrides:
      toString in class Object