public class MinWithComparator<T> extends ComparisonAggregator<T>
This aggregator computes the minimum of aggregated tuples in a stream. It uses given @{code comparator} for comparing two values in a stream.
ComparisonAggregator.State| Constructor and Description |
|---|
MinWithComparator(Comparator<T> comparator) |
MinWithComparator(String inputFieldName,
Comparator<T> comparator) |
| Modifier and Type | Method and Description |
|---|---|
protected T |
compare(T value1,
T value2) |
String |
toString() |
aggregate, complete, init, valueFromTuplecleanup, preparepublic MinWithComparator(String inputFieldName, Comparator<T> comparator)
public MinWithComparator(Comparator<T> comparator)
Copyright © 2021 The Apache Software Foundation. All rights reserved.