Class Max
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.BaseAggregator<ComparisonAggregator.State>
org.apache.storm.trident.operation.builtin.ComparisonAggregator<Comparable<Object>>
org.apache.storm.trident.operation.builtin.Max
- All Implemented Interfaces:
Serializable,Aggregator<ComparisonAggregator.State>,Operation
This aggregator computes the maximum of aggregated tuples in a stream. It assumes that the tuple has one value and it is an instance of
Comparable.- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregator
ComparisonAggregator.State -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Comparable<Object>compare(Comparable<Object> value1, Comparable<Object> value2) Methods inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregator
aggregate, complete, init, valueFromTupleMethods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
-
Constructor Details
-
Max
-
-
Method Details
-
compare
- Specified by:
comparein classComparisonAggregator<Comparable<Object>>
-