Class MinWithComparator<T>

All Implemented Interfaces:
Serializable, Aggregator<ComparisonAggregator.State>, Operation

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.
See Also: