Class MinWithComparator<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.MinWithComparator<T>
- All Implemented Interfaces:
- Serializable,- Aggregator<ComparisonAggregator.State>,- Operation
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:
- 
Nested Class SummaryNested classes/interfaces inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregatorComparisonAggregator.State
- 
Constructor SummaryConstructorsConstructorDescriptionMinWithComparator(String inputFieldName, Comparator<T> comparator) MinWithComparator(Comparator<T> comparator) 
- 
Method SummaryMethods inherited from class org.apache.storm.trident.operation.builtin.ComparisonAggregatoraggregate, complete, init, valueFromTupleMethods inherited from class org.apache.storm.trident.operation.BaseOperationcleanup, prepare
- 
Constructor Details- 
MinWithComparator
- 
MinWithComparator
 
- 
- 
Method Details- 
compare- Specified by:
- comparein class- ComparisonAggregator<T>
 
- 
toString
 
-