Package org.apache.storm.trident.operation.builtin

Class Summary

Class	Description
ComparisonAggregator<T>	Abstract Aggregator for comparing two values in a stream.
ComparisonAggregator.State
Count
Debug	Filter for debugging purposes.
Equals
FilterNull	Simple Filter implementation that filters out any tuples that have fields with a value of null.
FirstN	An Assembly implementation
FirstN.FirstNAgg
FirstN.FirstNSortedAgg
MapGet
Max	This aggregator computes the maximum of aggregated tuples in a stream.
MaxWithComparator<T>	This aggregator computes the maximum of aggregated tuples in a stream.
Min	This aggregator computes the minimum of aggregated tuples in a stream.
MinWithComparator<T>	This aggregator computes the minimum of aggregated tuples in a stream.
Negate	A Filter implementation that inverts another delegate Filter.
SnapshotGet
Sum
TupleCollectionGet