Uses of Class
org.apache.flink.table.runtime.operators.window.Window

Packages that use Window

Package	Description
org.apache.flink.table.runtime.operators.window
org.apache.flink.table.runtime.operators.window.assigners
org.apache.flink.table.runtime.operators.window.internal
org.apache.flink.table.runtime.operators.window.triggers

Uses of Window in org.apache.flink.table.runtime.operators.window

Classes in org.apache.flink.table.runtime.operators.window with type parameters of type Window

Modifier and Type	Class and Description
class	AggregateWindowOperator<K,W extends Window> A WindowOperator for grouped window aggregates.
class	TableAggregateWindowOperator<K,W extends Window> A WindowOperator for grouped and windowed table aggregates.
class	WindowOperator<K,W extends Window> An operator that implements the logic for windowing based on a WindowAssigner and Trigger.

Subclasses of Window in org.apache.flink.table.runtime.operators.window

Modifier and Type	Class and Description
class	CountWindow A Window that represents a count window.
class	TimeWindow A Window that represents a time interval from start (inclusive) to end (exclusive).

Methods in org.apache.flink.table.runtime.operators.window with parameters of type Window

Modifier and Type	Method and Description
int	TimeWindow.compareTo(Window o)
int	CountWindow.compareTo(Window o)

Uses of Window in org.apache.flink.table.runtime.operators.window.assigners

Classes in org.apache.flink.table.runtime.operators.window.assigners with type parameters of type Window

Modifier and Type	Class and Description
class	MergingWindowAssigner<W extends Window> A WindowAssigner that can merge windows.
class	PanedWindowAssigner<W extends Window> A WindowAssigner that window can be split into panes.
class	WindowAssigner<W extends Window> A WindowAssigner assigns zero or more Windows to an element.

Uses of Window in org.apache.flink.table.runtime.operators.window.internal

Classes in org.apache.flink.table.runtime.operators.window.internal with type parameters of type Window

Modifier and Type	Class and Description
class	GeneralWindowProcessFunction<K,W extends Window> The general implementation of InternalWindowProcessFunction.
class	InternalWindowProcessFunction<K,W extends Window> The internal interface for functions that process over grouped windows.
static interface	InternalWindowProcessFunction.Context<K,W extends Window> Information available in an invocation of methods of InternalWindowProcessFunction.
class	MergingWindowProcessFunction<K,W extends Window> The implementation of InternalWindowProcessFunction for MergingWindowAssigner.
class	MergingWindowSet<W extends Window> Utility for keeping track of merging Windows when using a MergingWindowAssigner in a WindowOperator.
class	PanedWindowProcessFunction<K,W extends Window> The implementation of InternalWindowProcessFunction for PanedWindowAssigner.

Uses of Window in org.apache.flink.table.runtime.operators.window.triggers

Classes in org.apache.flink.table.runtime.operators.window.triggers with type parameters of type Window

Modifier and Type	Class and Description
static class	ElementTriggers.CountElement<W extends Window> A Trigger that fires at some point after a specified number of input elements have arrived.
static class	ElementTriggers.EveryElement<W extends Window> A Trigger that triggers on every element.
static class	EventTimeTriggers.AfterEndOfWindow<W extends Window> A Trigger that fires once the watermark passes the end of the window to which a pane belongs.
static class	EventTimeTriggers.AfterEndOfWindowEarlyAndLate<W extends Window> A composite Trigger that consist of AfterEndOfWindow and a early trigger and late trigger.
static class	EventTimeTriggers.AfterEndOfWindowNoLate<W extends Window> A composite Trigger that consist of AfterEndOfWindow and a late trigger.
static class	ProcessingTimeTriggers.AfterEndOfWindow<W extends Window> A Trigger that fires once the current system time passes the end of the window to which a pane belongs.
static class	ProcessingTimeTriggers.AfterEndOfWindowNoLate<W extends Window> A composite Trigger that consist of AfterEndOfWindow and a early trigger.
static class	ProcessingTimeTriggers.AfterFirstElementPeriodic<W extends Window> Trigger every a given interval, the first trigger time is interval after the first element in the pane.
class	Trigger<W extends Window> A Trigger determines when a pane of a window should be evaluated to emit the results for that part of the window.

Methods in org.apache.flink.table.runtime.operators.window.triggers with type parameters of type Window

Modifier and Type	Method and Description
static <W extends Window> ProcessingTimeTriggers.AfterEndOfWindow<W>	ProcessingTimeTriggers.afterEndOfWindow() Creates a trigger that fires when the processing time passes the end of the window.
static <W extends Window> EventTimeTriggers.AfterEndOfWindow<W>	EventTimeTriggers.afterEndOfWindow() Creates a trigger that fires when the watermark passes the end of the window.
static <W extends Window> ElementTriggers.CountElement<W>	ElementTriggers.count(long countElems) Creates a trigger that fires when the pane contains at lease countElems elements.
static <W extends Window> ElementTriggers.EveryElement<W>	ElementTriggers.every() Creates a new trigger that triggers on receiving of every element.
static <W extends Window> ProcessingTimeTriggers.AfterFirstElementPeriodic<W>	ProcessingTimeTriggers.every(java.time.Duration time) Creates a trigger that fires by a certain interval after reception of the first element.