Class BaseOperation
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
- All Implemented Interfaces:
- Serializable,- Operation
- Direct Known Subclasses:
- BaseAggregator,- BaseFilter,- BaseFunction,- BaseQueryFunction,- BaseStateUpdater,- ConsumerExecutor,- FlatMapFunctionExecutor,- MapFunctionExecutor
Convenience implementation of the 
Operation interface.
 Provides no-op implementations of the `prepare()` and `cleanup()` methods.
- See Also:
- 
Constructor SummaryConstructors
- 
Method Summary
- 
Constructor Details- 
BaseOperationpublic BaseOperation()
 
- 
- 
Method Details- 
prepareNo-op implementation.- Specified by:
- preparein interface- Operation
- Parameters:
- conf- the Storm configuration map
- context- the operation context which provides information such as the number of partitions in the stream, and the current partition index. It also provides methods for registering operation-specific metrics.
- See Also:
 
- 
cleanuppublic void cleanup()No-op implemnation.
 
-