org.apache.storm.trident.operation

Interface EachOperation

All Superinterfaces:

Operation, Serializable

All Known Subinterfaces:

Filter, Function, QueryFunction<S,T>

All Known Implementing Classes:

AbstractRedisStateQuerier, BaseFilter, BaseFunction, BaseQueryFunction, CassandraQuery, CombinerAggregatorInitImpl, ConsumerExecutor, Debug, Equals, EvaluationFilter, FilterExecutor, FilterNull, FlatMapFunctionExecutor, ForwardFunction, HBaseQuery, JdbcQuery, MapFunctionExecutor, MapGet, MqttPublishFunction, Negate, PrintFunction, PrintFunction, RedisClusterStateQuerier, RedisStateQuerier, SnapshotGet, Split, StringLength, TransactionalTridentEventCount.LoggingFilter, TridentReach.ExpandList, TridentWordCount.Split, TrueFilter, TrueFilter, TupleCollectionGet, TuplifyArgs

public interface EachOperation
extends Operation

Method Summary

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup, prepare