Uses of Interface
org.apache.storm.streams.windowing.Window
Packages that use Window
-
Uses of Window in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type WindowModifier and TypeMethodDescriptionPairStream<K,Iterable<V>> PairStream.groupByKeyAndWindow(Window<?, ?> window) Returns a new stream where the values are grouped by keys and the given window.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.PairStream<K,V> Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.Returns a new stream consisting of the elements that fall within the window as specified by the window parameter. -
Uses of Window in org.apache.storm.streams.windowing
Classes in org.apache.storm.streams.windowing that implement WindowModifier and TypeClassDescriptionclassBaseWindow<L,I> classSlidingWindows<L,I> A sliding window specification based on a window length and sliding interval.classA tumbling window specification.