Package org.apache.storm.trident.operation

Interface Summary

Interface	Description
Aggregator<T>
Assembly	The Assembly interface provides a means to encapsulate logic applied to a Stream.
CombinerAggregator<T>
Consumer	Represents an operation that accepts a single input argument and returns no result.
EachOperation
Filter	Filters take in a tuple as input and decide whether or not to keep that tuple or not.
FlatMapFunction	A one to many transformation function.
Function	A function takes in a set of input fields and emits zero or more tuples as output.
GroupedMultiReducer<T>
ITridentResource	This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.
MapFunction	A one-one transformation function.
MultiReducer<T>
Operation	Parent interface for Trident Filters and Functions.
OperationAwareFlatMapFunction	A one to many transformation function which is aware of Operation (lifecycle of the Trident component).
OperationAwareMapFunction	A one-one transformation function which is aware of Operation (lifecycle of the Trident component).
ReducerAggregator<T>
TridentCollector	Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Class Summary

Class	Description
BaseAggregator<T>
BaseFilter
BaseFunction
BaseMultiReducer<T>
BaseOperation	Convenience implementation of the Operation interface.
DefaultResourceDeclarer<T extends DefaultResourceDeclarer>	Default implementation of resources declarer.
TridentMultiReducerContext
TridentOperationContext