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.