Uses of Interface
org.apache.storm.streams.operations.Reducer
-
Uses of Reducer in org.apache.storm.streams
Modifier and TypeMethodDescriptionPerforms a reduction on the elements of this stream, by repeatedly applying the reducer.PairStream<K,
V> PairStream.reduceByKey
(Reducer<V> reducer) Performs a reduction on the values for each key of this stream by repeatedly applying the reducer.PairStream<K,
V> PairStream.reduceByKeyAndWindow
(Reducer<V> reducer, Window<?, ?> window) Returns a new stream where the values that arrive within a window having the same key will be reduced by repeatedly applying the reducer. -
Uses of Reducer in org.apache.storm.streams.processors
ModifierConstructorDescriptionReduceByKeyProcessor
(Reducer<V> reducer) ReduceProcessor
(Reducer<T> reducer)