Interface | Description |
---|---|
AllWindowFunction<IN,OUT,W extends Window> |
Base interface for functions that are evaluated over non-grouped windows,
i.e., windows over all stream partitions.
|
StatefulFunction<I,O,S> |
Trait implementing the functionality necessary to apply stateful functions in
RichFunctions without exposing the OperatorStates to the user.
|
WindowFunction<IN,OUT,KEY,W extends Window> |
Base interface for functions that are evaluated over keyed (grouped) windows.
|
Class | Description |
---|---|
ProcessAllWindowFunction<IN,OUT,W extends Window> |
Base abstract class for functions that are evaluated over keyed (grouped)
windows using a context for retrieving extra information.
|
ProcessWindowFunction<IN,OUT,KEY,W extends Window> |
Base abstract class for functions that are evaluated over keyed (grouped)
windows using a context for retrieving extra information.
|
RichAllWindowFunction<IN,OUT,W extends Window> |
Rich variant of the
AllWindowFunction . |
RichProcessAllWindowFunction<IN,OUT,W extends Window> | Deprecated
use [[ProcessAllWindowFunction]] instead.
|
RichProcessWindowFunction<IN,OUT,KEY,W extends Window> | Deprecated
use [[ProcessWindowFunction]] instead.
|
RichWindowFunction<IN,OUT,KEY,W extends Window> |
Rich variant of the
WindowFunction . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.