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
The parent interface for any kind of streaming operation.