| 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 `Filter`s and `Function`s.
|
| 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).
|