IN
- The type of the input value.OUT
- The type of the output value.W
- The type of the window.@Internal public class InternalProcessAllWindowContext<IN,OUT,W extends Window> extends ProcessAllWindowFunction.Context
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
globalState()
State accessor for per-key global state.
|
W |
window() |
KeyedStateStore |
windowState()
State accessor for per-key and per-window state.
|
public W window()
window
in class ProcessAllWindowFunction.Context
public KeyedStateStore windowState()
ProcessAllWindowFunction.Context
NOTE:If you use per-window state you have to ensure that you clean it up
by implementing ProcessWindowFunction.clear(ProcessWindowFunction.Context)
.
windowState
in class ProcessAllWindowFunction.Context
public KeyedStateStore globalState()
ProcessAllWindowFunction.Context
globalState
in class ProcessAllWindowFunction.Context
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.