Uses of Interface
org.apache.flink.table.runtime.functions.CleanupState
-
Packages that use CleanupState Package Description org.apache.flink.table.runtime.functions org.apache.flink.table.runtime.operators.over -
-
Uses of CleanupState in org.apache.flink.table.runtime.functions
Classes in org.apache.flink.table.runtime.functions that implement CleanupState Modifier and Type Class Description classKeyedProcessFunctionWithCleanupState<K,IN,OUT>A function that processes elements of a stream, and could cleanup state. -
Uses of CleanupState in org.apache.flink.table.runtime.operators.over
Classes in org.apache.flink.table.runtime.operators.over that implement CleanupState Modifier and Type Class Description classAbstractRowTimeUnboundedPrecedingOver<K>A basic implementation to support unbounded event-time over-window.classProcTimeRowsBoundedPrecedingFunction<K>Process Function for ROW clause processing-time bounded OVER window.classRowTimeRangeUnboundedPrecedingFunction<K>A ProcessFunction to support unbounded RANGE window.classRowTimeRowsBoundedPrecedingFunction<K>Process Function for ROWS clause event-time bounded OVER window.classRowTimeRowsUnboundedPrecedingFunction<K>A ProcessFunction to support unbounded ROWS window.
-