Package org.apache.flink.table.runtime.operators.window.tvf.common
-
Interface Summary Interface Description ClockService A clock service which can get current processing time.SyncStateWindowProcessor<W> A processor that processes elements for windows.SyncStateWindowProcessor.SyncStateContext<W> Information available in an invocation of methods ofSyncStateWindowProcessor.WindowAssigner WindowAssigner is used to assign windows to elements.WindowProcessor<W,C extends WindowProcessor.Context<W>> A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowProcessor.Context<W> Information available in an invocation of methods ofWindowProcessor.WindowTimerService<W> Interface for working with window time and timers which considers timezone for window splitting. -
Class Summary Class Description WindowAggOperator<K,W> We divide windows into 2 categories: Aligned Windows and Unaligned Windows.WindowTimerServiceBase<W> A base implement ofWindowTimerService.