Package com.tangosol.util.aggregator

Class TopNAggregator.PartialResult<E>

java.lang.Object
java.util.AbstractCollection<E>
com.tangosol.util.SortedBag<E>
com.tangosol.util.aggregator.TopNAggregator.PartialResult<E>
All Implemented Interfaces:
ExternalizableLite, PortableObject, Serializable, Iterable<E>, Collection<E>
Enclosing class:
TopNAggregator<K,V,T,E>
public static class TopNAggregator.PartialResult<E> extends SortedBag<E> implements ExternalizableLite, PortableObject
The sorted partial result.
See Also:

  • Field Details

    • m_cMaxSize

      protected int m_cMaxSize
      The maximum size of this partial result.

    • m_comparator_copy

      protected Comparator<? super E> m_comparator_copy
      The comparator used to compare logical elements. Developers should NOT rely on this field, rely on TopNAggregator.m_comparator instead as this field will eventually be removed.

  • Constructor Details

    • PartialResult

      public PartialResult()
      Default constructor.

    • PartialResult

      public PartialResult(Comparator<? super E> comparator, int cMaxSize)
      Construct a PartialResult using the specified comparator.
      Parameters:
      comparator - the comparator
      cMaxSize - the maximum size of this partial result

  • Method Details

    • merge

      public TopNAggregator.PartialResult<E> merge(TopNAggregator.PartialResult<E> result)
      Merge single PartialResult into this PartialResult.
      Parameters:
      result - the partial result to merge
      Returns:
      this PartialResult

    • addAll

      public void addAll(Iterator<E> iterValues)
      Add all specified values to this PartialResult.
      Parameters:
      iterValues - the values to add

    • add

      public boolean add(E value)
      Description copied from class: SortedBag
      Specified by:
      add in interface Collection<E>
      Overrides:
      add in class SortedBag<E>

    • 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.
      Specified by:
      readExternal in interface ExternalizableLite
      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.
      Specified by:
      writeExternal in interface ExternalizableLite
      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.
      Specified by:
      readExternal in interface PortableObject
      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.
      Specified by:
      writeExternal in interface PortableObject
      Parameters:
      out - the PofWriter to which to write the object's state
      Throws:
      IOException - if an I/O error occurs