Package | Description |
---|---|
org.apache.storm.streams | |
org.apache.storm.streams.windowing |
Modifier and Type | Method and 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.
|
Modifier and Type | Class and 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.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.