storm.trident.operation

Interface Operation

All Superinterfaces:

Serializable

All Known Subinterfaces:

Aggregator<T>, EachOperation, Filter, Function, QueryFunction<S,T>, StateUpdater<S>

All Known Implementing Classes:

BaseAggregator, BaseFilter, BaseFunction, BaseOperation, BaseQueryFunction, BaseStateUpdater, ChainedAggregatorImpl, CombinerAggregatorCombineImpl, CombinerAggregatorInitImpl, CombinerAggStateUpdater, CountAsAggregator, Debug, Equals, FilterExecutor, FilterNull, FirstN.FirstNAgg, FirstN.FirstNSortedAgg, GroupedAggregator, MapCombinerAggStateUpdater, MapGet, MapReducerAggStateUpdater, Negate, ReducerAggregatorImpl, ReducerAggStateUpdater, SingleEmitAggregator, SnapshotGet, Split, StringLength, TrueFilter, TrueFilter, TupleCollectionGet, TuplifyArgs

public interface Operation
extends Serializable

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
void	prepare(Map conf, TridentOperationContext context)

Method Detail

prepare

void prepare(Map conf,
           TridentOperationContext context)

cleanup

void cleanup()