org.apache.flink.streaming.api.functions.windowing

Class InternalProcessApplyAllWindowContext<IN,OUT,W extends Window>

java.lang.Object

org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction.Context

org.apache.flink.streaming.api.functions.windowing.InternalProcessApplyAllWindowContext<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 InternalProcessApplyAllWindowContext<IN,OUT,W extends Window>
extends ProcessAllWindowFunction.Context

Internal reusable context wrapper.

Method Summary

Modifier and Type	Method and 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 the OutputTag.
W	window()
KeyedStateStore	windowState() State accessor for per-key and per-window state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

window

public W window()

Specified by:

window in class ProcessAllWindowFunction.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 class ProcessAllWindowFunction.Context

globalState

public KeyedStateStore globalState()

Description copied from class: ProcessAllWindowFunction.Context

State accessor for per-key global state.

Specified by:

globalState in class ProcessAllWindowFunction.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 the OutputTag.

Specified by:

output in class ProcessAllWindowFunction.Context

Parameters:

outputTag - the OutputTag that identifies the side output to emit to.

value - The record to emit.