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
,EsUpdater
,FilterExecutor
,FilterNull
,FirstN.FirstNAgg
,FirstN.FirstNSortedAgg
,FlatMapFunctionExecutor
,GroupedAggregator
,HdfsUpdater
,HiveUpdater
,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.
-