Uses of Class
org.apache.flink.table.runtime.functions.KeyedProcessFunctionWithCleanupState

Packages that use KeyedProcessFunctionWithCleanupState

Package	Description
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 KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.aggregate

Subclasses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.aggregate

Modifier and Type	Class and Description
class	GroupAggFunction Aggregate Function used for the groupby (without window) aggregate.
class	GroupTableAggFunction Aggregate Function used for the groupby (without window) table aggregate.

Uses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.deduplicate

Subclasses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.deduplicate

Modifier and Type	Class and Description
class	DeduplicateKeepFirstRowFunction This function is used to deduplicate on keys and keeps only first row.
class	DeduplicateKeepLastRowFunction This function is used to deduplicate on keys and keeps only last row.

Uses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.over

Subclasses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.over

Modifier and Type	Class and Description
class	AbstractRowTimeUnboundedPrecedingOver<K> A basic implementation to support unbounded event-time over-window.
class	ProcTimeRangeBoundedPrecedingFunction<K> Process Function used for the aggregate in bounded proc-time OVER window.
class	ProcTimeRowsBoundedPrecedingFunction<K> Process Function for ROW clause processing-time bounded OVER window.
class	ProcTimeUnboundedPrecedingFunction<K> Process Function for processing-time unbounded OVER window.
class	RowTimeRangeBoundedPrecedingFunction<K> Process Function for RANGE clause event-time bounded OVER window.
class	RowTimeRangeUnboundedPrecedingFunction<K> A ProcessFunction to support unbounded RANGE window.
class	RowTimeRowsBoundedPrecedingFunction<K> Process Function for ROWS clause event-time bounded OVER window.
class	RowTimeRowsUnboundedPrecedingFunction<K> A ProcessFunction to support unbounded ROWS window.

Uses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.rank

Subclasses of KeyedProcessFunctionWithCleanupState in org.apache.flink.table.runtime.operators.rank

Modifier and Type	Class and Description
class	AbstractTopNFunction Base class for TopN Function.
class	AppendOnlyTopNFunction The function could and only could handle append input stream.
class	RetractableTopNFunction The function could handle retract stream.
class	UpdatableTopNFunction The function could handle update input stream.