Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.common.SyncStateWindowProcessor.SyncStateContext
-
-
Uses of SyncStateWindowProcessor.SyncStateContext in org.apache.flink.table.runtime.operators.aggregate.window.processors
Methods in org.apache.flink.table.runtime.operators.aggregate.window.processors with parameters of type SyncStateWindowProcessor.SyncStateContext Modifier and Type Method Description voidAbstractSliceSyncStateWindowAggProcessor. open(SyncStateWindowProcessor.SyncStateContext<Long> context)voidAbstractSyncStateWindowAggProcessor. open(SyncStateWindowProcessor.SyncStateContext<W> context)voidUnsliceSyncStateWindowAggProcessor. open(SyncStateWindowProcessor.SyncStateContext<TimeWindow> context) -
Uses of SyncStateWindowProcessor.SyncStateContext in org.apache.flink.table.runtime.operators.deduplicate.window.processors
Methods in org.apache.flink.table.runtime.operators.deduplicate.window.processors with parameters of type SyncStateWindowProcessor.SyncStateContext Modifier and Type Method Description voidRowTimeSyncStateWindowDeduplicateProcessor. open(SyncStateWindowProcessor.SyncStateContext<Long> context) -
Uses of SyncStateWindowProcessor.SyncStateContext in org.apache.flink.table.runtime.operators.rank.window.processors
Methods in org.apache.flink.table.runtime.operators.rank.window.processors with parameters of type SyncStateWindowProcessor.SyncStateContext Modifier and Type Method Description voidSyncStateWindowRankProcessor. open(SyncStateWindowProcessor.SyncStateContext<Long> context)
-