Class MaxWithComparator<T>
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.BaseAggregator<ComparisonAggregator.State>
org.apache.storm.trident.operation.builtin.ComparisonAggregator<T>
org.apache.storm.trident.operation.builtin.MaxWithComparator<T>
- All Implemented Interfaces:
Serializable
,Aggregator<ComparisonAggregator.State>
,Operation
This aggregator computes the maximum of aggregated tuples in a stream. It uses given
comparator
for comparing two values in a
stream.- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregator
ComparisonAggregator.State
-
Constructor Summary
ConstructorDescriptionMaxWithComparator
(String inputFieldName, Comparator<T> comparator) MaxWithComparator
(Comparator<T> comparator) -
Method Summary
Methods inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregator
aggregate, complete, init, valueFromTuple
Methods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
-
Constructor Details
-
MaxWithComparator
-
MaxWithComparator
-
-
Method Details
-
compare
- Specified by:
compare
in classComparisonAggregator<T>
-
toString
-