Package org.apache.flink.table.runtime.operators.window.tvf.unslicing

Interface UnslicingSyncStateWindowProcessor<W>

All Superinterfaces:

Serializable, SyncStateWindowProcessor<W>, WindowProcessor<W,SyncStateWindowProcessor.SyncStateContext<W>>

All Known Implementing Classes:

UnsliceSyncStateWindowAggProcessor

@Internal
public interface UnslicingSyncStateWindowProcessor<W>
extends SyncStateWindowProcessor<W>

The UnslicingSyncStateWindowProcessor is an optimized processing for unaligned windows.

A UnslicingSyncStateWindowProcessor usually leverages the UnsliceAssigner to assign slices and calculate based on the window.

Note: Currently, the UnslicingSyncStateWindowProcessor only support session time window.

See more details in WindowAggOperator.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.SyncStateWindowProcessor

SyncStateWindowProcessor.SyncStateContext<W>

Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.WindowProcessor

WindowProcessor.Context<W>

Method Summary

Methods inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.SyncStateWindowProcessor

advanceProgress, clearWindow, fireWindow, prepareCheckpoint, processElement

Methods inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.WindowProcessor

close, createWindowSerializer, initializeWatermark, open