Interface | Description |
---|---|
AllWindowFunction<IN,OUT,W extends Window> |
Base interface for functions that are evaluated over non-keyed windows.
|
WindowFunction<IN,OUT,KEY,W extends Window> |
Base interface for functions that are evaluated over keyed (grouped) windows.
|
Class | Description |
---|---|
FoldApplyAllWindowFunction<W extends Window,T,ACC> | |
FoldApplyWindowFunction<K,W extends Window,T,ACC> | |
PassThroughAllWindowFunction<W extends Window,T> | |
PassThroughWindowFunction<K,W extends Window,T> | |
ReduceApplyAllWindowFunction<W extends Window,T,R> | |
ReduceApplyWindowFunction<K,W extends Window,T,R> | |
ReduceIterableAllWindowFunction<W extends Window,T> | |
ReduceIterableWindowFunction<K,W extends Window,T> | |
RichAllWindowFunction<IN,OUT,W extends Window> | |
RichWindowFunction<IN,OUT,KEY,W extends Window> |
Rich variant of the
WindowFunction . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.