Uses of Interface
org.apache.storm.streams.windowing.Window

Packages that use Window

Package	Description
org.apache.storm.streams
org.apache.storm.streams.windowing

Uses of Window in org.apache.storm.streams

Methods in org.apache.storm.streams with parameters of type Window

Modifier and Type	Method	Description
PairStream<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>	PairStream.window(Window<?,?> window)	Returns a new stream consisting of the elements that fall within the window as specified by the window parameter.
Stream<T>	Stream.window(Window<?,?> window)	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 Window

Modifier and Type	Class	Description
class	BaseWindow<L,I>
class	SlidingWindows<L,I>	A sliding window specification based on a window length and sliding interval.
class	TumblingWindows<L>	A tumbling window specification.