| 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 | 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 |
Copyright © 2021 The Apache Software Foundation. All rights reserved.