Package org.apache.flink.table.runtime.generated

Interface FilterCondition.Context

Enclosing interface:

FilterCondition

public static interface FilterCondition.Context

Context for generating expressions such as e.g. CURRENT_WATERMARK or STREAMRECORD_TIMESTAMP.

See Also:

ProcessFunction.Context

Field Summary

Fields

Modifier and Type	Field	Description
static FilterCondition.Context	INVALID_CONTEXT

Method Summary

Modifier and Type	Method	Description
static FilterCondition.Context	of(org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context context)
static FilterCondition.Context	of(org.apache.flink.streaming.api.functions.ProcessFunction.Context context)
org.apache.flink.streaming.api.TimerService	timerService()	A TimerService for querying time and registering timers.
Long	timestamp()	Timestamp of the element currently being processed or timestamp of a firing timer.

Field Detail

INVALID_CONTEXT

static final FilterCondition.Context INVALID_CONTEXT

Method Detail

timestamp

Long timestamp()

Timestamp of the element currently being processed or timestamp of a firing timer.

This might be null, depending on the stream's watermark strategy.

timerService

org.apache.flink.streaming.api.TimerService timerService()

A TimerService for querying time and registering timers.

of

static FilterCondition.Context of(org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context context)

of

static FilterCondition.Context of(org.apache.flink.streaming.api.functions.ProcessFunction.Context context)