org.apache.flink.streaming.runtime.operators.windowing.functions

Class InternalProcessWindowContext<IN,OUT,KEY,W extends Window>

java.lang.Object

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

org.apache.flink.streaming.runtime.operators.windowing.functions.InternalProcessWindowContext<IN,OUT,KEY,W>

Type Parameters:

IN - The type of the input value.

OUT - The type of the output value.

KEY - The type of the key.

W - The type of the window.

All Implemented Interfaces:

Serializable

@Internal
public class InternalProcessWindowContext<IN,OUT,KEY,W extends Window>
extends ProcessWindowFunction.Context

Internal reusable context wrapper.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
long	currentProcessingTime() Returns the current processing time.
long	currentWatermark() Returns the current event-time watermark.
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() Returns the window that is being evaluated.
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()

Description copied from class: ProcessWindowFunction.Context

Returns the window that is being evaluated.

Specified by:

window in class ProcessWindowFunction.Context

currentProcessingTime

public long currentProcessingTime()

Description copied from class: ProcessWindowFunction.Context

Returns the current processing time.

Specified by:

currentProcessingTime in class ProcessWindowFunction.Context

currentWatermark

public long currentWatermark()

Description copied from class: ProcessWindowFunction.Context

Returns the current event-time watermark.

Specified by:

currentWatermark in class ProcessWindowFunction.Context

windowState

public KeyedStateStore windowState()

Description copied from class: ProcessWindowFunction.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(Context).

Specified by:

windowState in class ProcessWindowFunction.Context

globalState

public KeyedStateStore globalState()

Description copied from class: ProcessWindowFunction.Context

State accessor for per-key global state.

Specified by:

globalState in class ProcessWindowFunction.Context

output

public <X> void output(OutputTag<X> outputTag,
                       X value)

Description copied from class: ProcessWindowFunction.Context

Emits a record to the side output identified by the OutputTag.

Specified by:

output in class ProcessWindowFunction.Context

Parameters:

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

value - The record to emit.