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
public abstract class BaseAggregator<T> extends BaseOperation implements Aggregator<T>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BaseAggregator()
-
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
-
-