Class BaseAggregator<T>
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.BaseAggregator<T>
- All Implemented Interfaces:
Serializable
,Aggregator<T>
,Operation
- Direct Known Subclasses:
ComparisonAggregator
,CountAsAggregator
,FirstN.FirstNAgg
,FirstN.FirstNSortedAgg
- See Also:
-
Constructor Summary
-
Method Summary
Methods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.storm.trident.operation.Aggregator
aggregate, complete, init
-
Constructor Details
-
BaseAggregator
public BaseAggregator()
-