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
public class BaseOperation extends Object implements Operation
Convenience implementation of theOperationinterface.Provides no-op implementations of the `prepare()` and `cleanup()` methods.
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BaseOperation()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanup()No-op implemnation.voidprepare(Map<String,Object> conf, TridentOperationContext context)No-op implementation.
-
-
-
Method Detail
-
prepare
public void prepare(Map<String,Object> conf, TridentOperationContext context)
No-op implementation.- Specified by:
preparein 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:
TridentOperationContext
-
-