| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseFunction |
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseFunction |
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentOperationContext |
| Class and Description |
|---|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseFunction |
| BaseOperation
Convenience implementation of the
Operation interface. |
| CombinerAggregator |
| EachOperation |
| Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| Aggregator |
| Assembly
The
Assembly interface provides a means to encapsulate logic applied to a Stream. |
| CombinerAggregator |
| Consumer
Represents an operation that accepts a single input argument and returns no result.
|
| DefaultResourceDeclarer
Default implementation of resources declarer.
|
| 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 |
| MapFunction
A one-one transformation function.
|
| MultiReducer |
| ReducerAggregator |
| Class and Description |
|---|
| MultiReducer |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentMultiReducerContext |
| Class and Description |
|---|
| Aggregator |
| CombinerAggregator |
| Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
| ReducerAggregator |
| Class and Description |
|---|
| Aggregator |
| BaseOperation
Convenience implementation of the
Operation interface. |
| DefaultResourceDeclarer
Default implementation of resources declarer.
|
| 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.
|
| 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 |
| Operation
Parent interface for Trident
Filters and Functions. |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentMultiReducerContext |
| TridentOperationContext |
| Class and Description |
|---|
| Aggregator |
| Assembly
The
Assembly interface provides a means to encapsulate logic applied to a Stream. |
| BaseAggregator |
| BaseFilter |
| BaseOperation
Convenience implementation of the
Operation interface. |
| CombinerAggregator |
| EachOperation |
| Filter
Filters take in a tuple as input and decide whether or not to keep that tuple or not.
|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentOperationContext |
| Class and Description |
|---|
| Aggregator |
| BaseOperation
Convenience implementation of the
Operation interface. |
| CombinerAggregator |
| 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 |
| MapFunction
A one-one transformation function.
|
| MultiReducer |
| ReducerAggregator |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentMultiReducerContext |
| TridentOperationContext |
| Class and Description |
|---|
| DefaultResourceDeclarer
Default implementation of resources declarer.
|
| ITridentResource
This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.
|
| Class and Description |
|---|
| Aggregator |
| Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
| MultiReducer |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| BaseOperation
Convenience implementation of the
Operation interface. |
| CombinerAggregator |
| EachOperation |
| Operation
Parent interface for Trident
Filters and Functions. |
| ReducerAggregator |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| CombinerAggregator |
| ReducerAggregator |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentOperationContext |
| Class and Description |
|---|
| Aggregator |
| BaseAggregator |
| BaseFilter |
| BaseFunction |
| BaseOperation
Convenience implementation of the
Operation interface. |
| EachOperation |
| Function
A function takes in a set of input fields and emits zero or more tuples as output.
|
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| Class and Description |
|---|
| Aggregator |
| TridentCollector
Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
|
| TridentOperationContext |
Copyright © 2021 The Apache Software Foundation. All rights reserved.