public class Min extends ComparisonAggregator<Comparable<Object>>
This aggregator computes the minimum of aggregated tuples in a stream. It assumes that the tuple has one value and it is an instance of Comparable.
ComparisonAggregator.State| Modifier and Type | Method and Description |
|---|---|
protected Comparable<Object> |
compare(Comparable<Object> value1,
Comparable<Object> value2) |
aggregate, complete, init, valueFromTuplecleanup, preparepublic Min(String inputFieldName)
protected Comparable<Object> compare(Comparable<Object> value1, Comparable<Object> value2)
compare in class ComparisonAggregator<Comparable<Object>>Copyright © 2021 The Apache Software Foundation. All rights reserved.