org.apache.storm.streams.operations

Interface Operation

All Superinterfaces:

Serializable

All Known Subinterfaces:

BiFunction<T,U,R>, CombinerAggregator<T,A,R>, Consumer<T>, FlatMapFunction<T,R>, Function<T,R>, PairFlatMapFunction<T,K,V>, PairFunction<T,K,V>, Predicate<T>, Reducer<T>, StateUpdater<T,S>, TupleValueMapper<T>, ValueJoiner<V1,V2,R>

All Known Implementing Classes:

Count, EvaluationCalc, EvaluationFilter, EvaluationFunction, IdentityFunction, LongSum, PairValueJoiner, PairValueMapper, PrintConsumer, StreamInsertMapToPairFunction, StreamsScanTupleValueMapper, ValueMapper, ValuesMapper

public interface Operation
extends Serializable

The parent interface for any kind of streaming operation.