Class ComparisonAggregator<T>

All Implemented Interfaces:
Serializable, Aggregator<ComparisonAggregator.State>, Operation
Direct Known Subclasses:
Max, MaxWithComparator, Min, MinWithComparator

public abstract class ComparisonAggregator<T> extends BaseAggregator<ComparisonAggregator.State>
Abstract Aggregator for comparing two values in a stream.
See Also: