Uses of Class
org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context

Packages that use KeyedProcessFunction.Context

Package	Description
org.apache.flink.streaming.api.functions
org.apache.flink.table.runtime.functions
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.rank

Uses of KeyedProcessFunction.Context in org.apache.flink.streaming.api.functions

Subclasses of KeyedProcessFunction.Context in org.apache.flink.streaming.api.functions

Modifier and Type	Class and Description
class	KeyedProcessFunction.OnTimerContext Information available in an invocation of KeyedProcessFunction.onTimer(long, OnTimerContext, Collector).

Methods in org.apache.flink.streaming.api.functions with parameters of type KeyedProcessFunction.Context

Modifier and Type	Method and Description
abstract void	KeyedProcessFunction.processElement(I value, KeyedProcessFunction.Context ctx, Collector<O> out) Process one element from the input stream.

Uses of KeyedProcessFunction.Context in org.apache.flink.table.runtime.functions

Methods in org.apache.flink.table.runtime.functions with parameters of type KeyedProcessFunction.Context

Modifier and Type	Method and Description
protected void	KeyedProcessFunctionWithCleanupState.registerProcessingCleanupTimer(KeyedProcessFunction.Context ctx, long currentTime)

Uses of KeyedProcessFunction.Context in org.apache.flink.table.runtime.operators.aggregate

Methods in org.apache.flink.table.runtime.operators.aggregate with parameters of type KeyedProcessFunction.Context

Modifier and Type	Method and Description
void	GroupTableAggFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	GroupAggFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)

Uses of KeyedProcessFunction.Context in org.apache.flink.table.runtime.operators.deduplicate

Methods in org.apache.flink.table.runtime.operators.deduplicate with parameters of type KeyedProcessFunction.Context

Modifier and Type	Method and Description
void	DeduplicateKeepLastRowFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	DeduplicateKeepFirstRowFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)

Uses of KeyedProcessFunction.Context in org.apache.flink.table.runtime.operators.over

Methods in org.apache.flink.table.runtime.operators.over with parameters of type KeyedProcessFunction.Context

Modifier and Type	Method and Description
void	ProcTimeUnboundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeRangeBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	ProcTimeRowsBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeRowsBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	RowTimeRangeBoundedPrecedingFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	AbstractRowTimeUnboundedPrecedingOver.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out) Puts an element from the input stream into state if it is not late.

Uses of KeyedProcessFunction.Context in org.apache.flink.table.runtime.operators.rank

Methods in org.apache.flink.table.runtime.operators.rank with parameters of type KeyedProcessFunction.Context

Modifier and Type	Method and Description
void	UpdatableTopNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)
void	RetractableTopNFunction.processElement(RowData input, KeyedProcessFunction.Context ctx, Collector<RowData> out)
void	AppendOnlyTopNFunction.processElement(RowData input, KeyedProcessFunction.Context context, Collector<RowData> out)