Class InternalProcessAllWindowContext<IN,OUT,W extends Window>
- java.lang.Object
-
- org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction.Context
-
- org.apache.flink.streaming.runtime.operators.windowing.functions.InternalProcessAllWindowContext<IN,OUT,W>
-
- Type Parameters:
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
Internal reusable context wrapper.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KeyedStateStore
globalState()
State accessor for per-key global state.<X> void
output(OutputTag<X> outputTag, X value)
Emits a record to the side output identified by theOutputTag
.W
window()
KeyedStateStore
windowState()
State accessor for per-key and per-window state.
-
-
-
Method Detail
-
window
public W window()
- Specified by:
window
in classProcessAllWindowFunction.Context
- Returns:
- The window that is being evaluated.
-
windowState
public KeyedStateStore windowState()
Description copied from class:ProcessAllWindowFunction.Context
State accessor for per-key and per-window state.NOTE:If you use per-window state you have to ensure that you clean it up by implementing
ProcessWindowFunction.clear(ProcessWindowFunction.Context)
.- Specified by:
windowState
in classProcessAllWindowFunction.Context
-
globalState
public KeyedStateStore globalState()
Description copied from class:ProcessAllWindowFunction.Context
State accessor for per-key global state.- Specified by:
globalState
in classProcessAllWindowFunction.Context
-
output
public <X> void output(OutputTag<X> outputTag, X value)
Description copied from class:ProcessAllWindowFunction.Context
Emits a record to the side output identified by theOutputTag
.- Specified by:
output
in classProcessAllWindowFunction.Context
- Parameters:
outputTag
- theOutputTag
that identifies the side output to emit to.value
- The record to emit.
-
-