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 Summary
-
Method Summary
-
Constructor Details
-
BaseOperation
public BaseOperation()
-
-
Method Details
-
prepare
No-op implementation.- Specified by:
prepare
in interfaceOperation
- Parameters:
conf
- the Storm configuration mapcontext
- 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:
-
cleanup
public void cleanup()No-op implemnation.
-