Class ComparableMaxAggregator<K, V extends Comparable<? super V>>

java.lang.Object
com.loomcache.server.compute.ComparableMaxAggregator<K,V>
Type Parameters:
K - the type of the key
V - the comparable value type
All Implemented Interfaces:
Aggregator<K,V,V>
public class ComparableMaxAggregator<K, V extends Comparable<? super V>> extends Object implements Aggregator<K,V,V>
Built-in aggregator that returns the maximum value by natural ordering.

  • Constructor Details

    • ComparableMaxAggregator

      public ComparableMaxAggregator()
      Create a new comparable max aggregator.

  • Method Details

    • accumulate

      public void accumulate(Map.Entry<K,V> entry)
      Description copied from interface: Aggregator
      Accumulate a single entry into this aggregator.

      This method is called once for each entry in the map during the scan.

      Specified by:
      accumulate in interface Aggregator<K, V extends Comparable<? super V>, V extends Comparable<? super V>>
      Parameters:
      entry - the entry to accumulate (may be null if entry was deleted)

    • combine

      public Aggregator<K,V,V> combine(Aggregator<K,V,V> other)
      Description copied from interface: Aggregator
      Combine this aggregator with another from a parallel execution.

      This method is used to merge results from multiple parallel aggregations into a single result. Implementations should combine the internal state of both aggregators.

      Specified by:
      combine in interface Aggregator<K, V extends Comparable<? super V>, V extends Comparable<? super V>>
      Parameters:
      other - the other aggregator to combine with (must not be null)
      Returns:
      a new aggregator combining both results (may be this or other)

    • aggregate

      public @Nullable V aggregate()
      Description copied from interface: Aggregator
      Get the final aggregated result.

      This is called after all entries have been accumulated and all partial results have been combined.

      Specified by:
      aggregate in interface Aggregator<K, V extends Comparable<? super V>, V extends Comparable<? super V>>
      Returns:
      the aggregated result