Class MaxAggregator<K, V extends Number>

java.lang.Object
com.loomcache.server.compute.MaxAggregator<K,V>
Type Parameters:
K - the type of the key
V - the type of the value (should be numeric)
All Implemented Interfaces:
Aggregator<K,V,Double>
public class MaxAggregator<K, V extends Number> extends Object implements Aggregator<K,V,Double>
Built-in aggregator that finds the maximum numeric value in the map.

Values must implement Number interface and be comparable. Non-numeric values are skipped. Returns -Double.MAX_VALUE if map is empty.

  • Constructor Details

    • MaxAggregator

      public MaxAggregator()
      Create a new 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 Number, Double>
      Parameters:
      entry - the entry to accumulate (may be null if entry was deleted)

    • combine

      public Aggregator<K,V,Double> combine(Aggregator<K,V,Double> 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 Number, Double>
      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 Double 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 Number, Double>
      Returns:
      the aggregated result