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

Interface InternalWindowFunction.InternalWindowContext

All Superinterfaces:

Serializable

All Known Implementing Classes:

WindowOperator.WindowContext

Enclosing interface:

InternalWindowFunction<IN,OUT,KEY,W extends Window>

public static interface InternalWindowFunction.InternalWindowContext
extends Serializable

A context for InternalWindowFunction, similar to ProcessWindowFunction.Context but for internal use.

Method Summary

Modifier and Type	Method and Description
long	currentProcessingTime()
long	currentWatermark()
KeyedStateStore	globalState()
<X> void	output(OutputTag<X> outputTag, X value)
KeyedStateStore	windowState()

Method Detail

currentProcessingTime

long currentProcessingTime()

currentWatermark

long currentWatermark()

windowState

KeyedStateStore windowState()

globalState

KeyedStateStore globalState()

output

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