org.apache.flink.table.runtime.functions

Interface CleanupState

All Known Implementing Classes:

AbstractPythonStreamGroupAggregateOperator, AbstractRowTimeUnboundedPrecedingOver, AbstractStreamArrowPythonBoundedRowsOperator, KeyedProcessFunctionWithCleanupState, ProcTimeRowsBoundedPrecedingFunction, PythonStreamGroupAggregateOperator, PythonStreamGroupTableAggregateOperator, RowTimeRangeUnboundedPrecedingFunction, RowTimeRowsBoundedPrecedingFunction, RowTimeRowsUnboundedPrecedingFunction, StreamArrowPythonProcTimeBoundedRowsOperator, StreamArrowPythonRowTimeBoundedRowsOperator

public interface CleanupState

Base interface for clean up state, both for ProcessFunction and CoProcessFunction.

Method Summary

Modifier and Type	Method and Description
default void	registerProcessingCleanupTimer(ValueState<Long> cleanupTimeState, long currentTime, long minRetentionTime, long maxRetentionTime, TimerService timerService)

Method Detail

registerProcessingCleanupTimer

default void registerProcessingCleanupTimer(ValueState<Long> cleanupTimeState,
                                            long currentTime,
                                            long minRetentionTime,
                                            long maxRetentionTime,
                                            TimerService timerService)
                                     throws Exception

Throws:

Exception