Interface Operation
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
Aggregator<T>,EachOperation,Filter,Function,OperationAwareFlatMapFunction,OperationAwareMapFunction,QueryFunction<S,,T> StateUpdater<S>
- All Known Implementing Classes:
AbstractRedisStateQuerier,AbstractRedisStateUpdater,BaseAggregator,BaseFilter,BaseFunction,BaseOperation,BaseQueryFunction,BaseStateUpdater,ChainedAggregatorImpl,CombinerAggregatorCombineImpl,CombinerAggregatorInitImpl,CombinerAggStateUpdater,ComparisonAggregator,ConsumerExecutor,CountAsAggregator,Debug,Equals,FilterExecutor,FilterNull,FirstN.FirstNAgg,FirstN.FirstNSortedAgg,FlatMapFunctionExecutor,GroupedAggregator,HdfsUpdater,JdbcQuery,JdbcUpdater,JmsUpdater,MapCombinerAggStateUpdater,MapFunctionExecutor,MapGet,MapReducerAggStateUpdater,Max,MaxWithComparator,Min,MinWithComparator,Negate,PrintFunction,RedisClusterStateQuerier,RedisClusterStateUpdater,RedisStateQuerier,RedisStateUpdater,ReducerAggregatorImpl,ReducerAggStateUpdater,SingleEmitAggregator,SnapshotGet,Split,StringLength,TridentKafkaStateUpdater,TridentReach.ExpandList,TridentWordCount.Split,TrueFilter,TrueFilter,TupleCollectionGet,TuplifyArgs,WindowsStateUpdater
Parent interface for Trident `Filter`s and `Function`s.
`Operation` defines two lifecycle methods for Trident components. The `prepare()` method is called once when the `Operation` is first initialized. The `cleanup()` method is called in local mode when the local cluster is being shut down. In distributed mode, the `cleanup()` method is not guaranteed to be called in every situation, but Storm will make a best effort call `cleanup()` whenever possible.
-
Method Summary
-
Method Details
-
prepare
Called when the `Operation` is first initialized.- 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
void cleanup()When running in local mode, called when the local cluster is being shut down.
-