Uses of Package
org.apache.flink.table.runtime.operators.window.tvf.common
-
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors Class Description WindowAssigner WindowAssigner is used to assign windows to elements.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.window Class Description WindowAssigner WindowAssigner is used to assign windows to elements. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.window.buffers Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.aggregate.window.processors Class Description ClockService A clock service which can get current processing time.SyncStateWindowProcessor A processor that processes elements for windows.SyncStateWindowProcessor.SyncStateContext Information available in an invocation of methods ofSyncStateWindowProcessor.WindowAssigner WindowAssigner is used to assign windows to elements.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowProcessor.Context Information available in an invocation of methods ofWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.deduplicate.window Class Description WindowAggOperator We divide windows into 2 categories: Aligned Windows and Unaligned Windows. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.deduplicate.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.deduplicate.window.processors Class Description SyncStateWindowProcessor A processor that processes elements for windows.SyncStateWindowProcessor.SyncStateContext Information available in an invocation of methods ofSyncStateWindowProcessor.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.join.window.utils Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.rank.window Class Description WindowAggOperator We divide windows into 2 categories: Aligned Windows and Unaligned Windows. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.rank.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.rank.window.processors Class Description SyncStateWindowProcessor A processor that processes elements for windows.SyncStateWindowProcessor.SyncStateContext Information available in an invocation of methods ofSyncStateWindowProcessor.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.async.tvf.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.async.tvf.common Class Description WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowProcessor.Context Information available in an invocation of methods ofWindowProcessor. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.async.tvf.slicing Class Description WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.tvf.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.tvf.common Class Description ClockService A clock service which can get current processing time.SyncStateWindowProcessor A processor that processes elements for windows.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowProcessor.Context Information available in an invocation of methods ofWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.tvf.slicing Class Description ClockService A clock service which can get current processing time.SyncStateWindowProcessor A processor that processes elements for windows.WindowAssigner WindowAssigner is used to assign windows to elements.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting.WindowTimerServiceBase A base implement ofWindowTimerService. -
Classes in org.apache.flink.table.runtime.operators.window.tvf.common used by org.apache.flink.table.runtime.operators.window.tvf.unslicing Class Description ClockService A clock service which can get current processing time.SyncStateWindowProcessor A processor that processes elements for windows.WindowAssigner WindowAssigner is used to assign windows to elements.WindowProcessor A base window processor provides common methods used forSyncStateWindowProcessorandAsyncStateWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting.WindowTimerServiceBase A base implement ofWindowTimerService.