Uses of Class
org.apache.flink.streaming.api.windowing.windows.Window

Packages that use Window

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.windowing.assigners
org.apache.flink.streaming.api.windowing.evictors
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.api.windowing.windows
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.operators.windowing.functions

Uses of Window in org.apache.flink.streaming.api.datastream

Classes in org.apache.flink.streaming.api.datastream with type parameters of type Window

Modifier and Type	Class	Description
class	AllWindowedStream<T,W extends Window>	A AllWindowedStream represents a data stream where the stream of elements is split into windows based on a WindowAssigner.
static class	CoGroupedStreams.WithWindow<T1,T2,KEY,W extends Window>	A co-group operation that has KeySelectors defined for both inputs as well as a WindowAssigner.
static class	JoinedStreams.WithWindow<T1,T2,KEY,W extends Window>	A join operation that has KeySelectors defined for both inputs as well as a WindowAssigner.
class	WindowedStream<T,K,W extends Window>	A WindowedStream represents a data stream where elements are grouped by key, and for each key, the stream of elements is split into windows based on a WindowAssigner.

Methods in org.apache.flink.streaming.api.datastream with type parameters of type Window

Modifier and Type	Method	Description
<W extends Window> CoGroupedStreams.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)	Specifies the window on which the co-group operation works.
<W extends Window> JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)	Specifies the window on which the join operation works.
<W extends Window> WindowedStream<T,KEY,W>	KeyedStream.window(WindowAssigner<? super T,W> assigner)	Windows this data stream to a WindowedStream, which evaluates windows over a key grouped stream.
<W extends Window> AllWindowedStream<T,W>	DataStream.windowAll(WindowAssigner<? super T,W> assigner)	Windows this data stream to a AllWindowedStream, which evaluates windows over a non key grouped stream.

Uses of Window in org.apache.flink.streaming.api.functions.windowing

Classes in org.apache.flink.streaming.api.functions.windowing with type parameters of type Window

Modifier and Type	Class	Description
class	AggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R>	A AllWindowFunction that composes an AggregateFunction and AllWindowFunction.
class	AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R>	A WindowFunction that composes an AggregateFunction and WindowFunction.
interface	AllWindowFunction<IN,OUT,W extends Window>	Base interface for functions that are evaluated over non-keyed windows.
class	InternalProcessApplyAllWindowContext<IN,OUT,W extends Window>	Internal reusable context wrapper.
class	InternalProcessApplyWindowContext<IN,OUT,KEY,W extends Window>	Internal reusable context wrapper.
class	PassThroughAllWindowFunction<W extends Window,T>	A AllWindowFunction that just emits each input element.
class	PassThroughWindowFunction<K,W extends Window,T>	A WindowFunction that just emits each input element.
class	ProcessAllWindowFunction<IN,OUT,W extends Window>	Base abstract class for functions that are evaluated over non-keyed windows using a context for retrieving extra information.
class	ProcessWindowFunction<IN,OUT,KEY,W extends Window>	Base abstract class for functions that are evaluated over keyed (grouped) windows using a context for retrieving extra information.
class	ReduceApplyAllWindowFunction<W extends Window,T,R>	Internal AllWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
class	ReduceApplyProcessAllWindowFunction<W extends Window,T,R>	Internal ProcessAllWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
class	ReduceApplyProcessWindowFunction<K,W extends Window,T,R>	Internal ProcessWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
class	ReduceApplyWindowFunction<K,W extends Window,T,R>	Internal WindowFunction that is used for implementing a fold on a window configuration that only allows WindowFunction and cannot directly execute a ReduceFunction.
class	RichAllWindowFunction<IN,OUT,W extends Window>	A RichFunction version of AllWindowFunction.
class	RichProcessAllWindowFunction<IN,OUT,W extends Window>	Deprecated. use ProcessAllWindowFunction instead
class	RichProcessWindowFunction<IN,OUT,KEY,W extends Window>	Deprecated. use ProcessWindowFunction instead
class	RichWindowFunction<IN,OUT,KEY,W extends Window>	Rich variant of the WindowFunction.
interface	WindowFunction<IN,OUT,KEY,W extends Window>	Base interface for functions that are evaluated over keyed (grouped) windows.

Uses of Window in org.apache.flink.streaming.api.windowing.assigners

Classes in org.apache.flink.streaming.api.windowing.assigners with type parameters of type Window

Modifier and Type	Class	Description
class	MergingWindowAssigner<T,W extends Window>	A WindowAssigner that can merge windows.
class	WindowAssigner<T,W extends Window>	A WindowAssigner assigns zero or more Windows to an element.

Uses of Window in org.apache.flink.streaming.api.windowing.evictors

Classes in org.apache.flink.streaming.api.windowing.evictors with type parameters of type Window

Modifier and Type	Class	Description
class	CountEvictor<W extends Window>	An Evictor that keeps up to a certain amount of elements.
class	DeltaEvictor<T,W extends Window>	An Evictor that keeps elements based on a DeltaFunction and a threshold.
interface	Evictor<T,W extends Window>	An Evictor can remove elements from a pane before/after the evaluation of WindowFunction and after the window evaluation gets triggered by a Trigger
class	TimeEvictor<W extends Window>	An Evictor that keeps elements for a certain amount of time.

Methods in org.apache.flink.streaming.api.windowing.evictors with type parameters of type Window

Modifier and Type	Method	Description
static <W extends Window> CountEvictor<W>	CountEvictor.of(long maxCount)	Creates a CountEvictor that keeps the given number of elements.
static <W extends Window> CountEvictor<W>	CountEvictor.of(long maxCount, boolean doEvictAfter)	Creates a CountEvictor that keeps the given number of elements in the pane Eviction is done before/after the window function based on the value of doEvictAfter.
static <T,W extends Window> DeltaEvictor<T,W>	DeltaEvictor.of(double threshold, DeltaFunction<T> deltaFunction)	Creates a DeltaEvictor from the given threshold and DeltaFunction.
static <T,W extends Window> DeltaEvictor<T,W>	DeltaEvictor.of(double threshold, DeltaFunction<T> deltaFunction, boolean doEvictAfter)	Creates a DeltaEvictor from the given threshold, DeltaFunction.
static <W extends Window> TimeEvictor<W>	TimeEvictor.of(Time windowSize)	Creates a TimeEvictor that keeps the given number of elements.
static <W extends Window> TimeEvictor<W>	TimeEvictor.of(Time windowSize, boolean doEvictAfter)	Creates a TimeEvictor that keeps the given number of elements.

Uses of Window in org.apache.flink.streaming.api.windowing.triggers

Classes in org.apache.flink.streaming.api.windowing.triggers with type parameters of type Window

Modifier and Type	Class	Description
class	ContinuousEventTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval.
class	ContinuousProcessingTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.
class	CountTrigger<W extends Window>	A Trigger that fires once the count of elements in a pane reaches the given count.
class	DeltaTrigger<T,W extends Window>	A Trigger that fires based on a DeltaFunction and a threshold.
class	ProcessingTimeoutTrigger<T,W extends Window>	A Trigger that can turn any Trigger into a timeout Trigger.
class	PurgingTrigger<T,W extends Window>	A trigger that can turn any Trigger into a purging Trigger.
class	Trigger<T,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.streaming.api.windowing.triggers with type parameters of type Window

Modifier and Type	Method	Description
static <W extends Window> ContinuousEventTimeTrigger<W>	ContinuousEventTimeTrigger.of(Time interval)	Creates a trigger that continuously fires based on the given interval.
static <W extends Window> ContinuousProcessingTimeTrigger<W>	ContinuousProcessingTimeTrigger.of(Time interval)	Creates a trigger that continuously fires based on the given interval.
static <W extends Window> CountTrigger<W>	CountTrigger.of(long maxCount)	Creates a trigger that fires once the number of elements in a pane reaches the given count.
static <T,W extends Window> DeltaTrigger<T,W>	DeltaTrigger.of(double threshold, DeltaFunction<T> deltaFunction, org.apache.flink.api.common.typeutils.TypeSerializer<T> stateSerializer)	Creates a delta trigger from the given threshold and DeltaFunction.
static <T,W extends Window> ProcessingTimeoutTrigger<T,W>	ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger, Duration timeout)	Creates a new ProcessingTimeoutTrigger that fires when the inner trigger is fired or when the timeout timer fires.
static <T,W extends Window> ProcessingTimeoutTrigger<T,W>	ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger, Duration timeout, boolean resetTimerOnNewRecord, boolean shouldClearOnTimeout)	Creates a new ProcessingTimeoutTrigger that fires when the inner trigger is fired or when the timeout timer fires.
static <T,W extends Window> PurgingTrigger<T,W>	PurgingTrigger.of(Trigger<T,W> nestedTrigger)	Creates a new purging trigger from the given Trigger.

Uses of Window in org.apache.flink.streaming.api.windowing.windows

Subclasses of Window in org.apache.flink.streaming.api.windowing.windows

Modifier and Type	Class	Description
class	GlobalWindow	The default window into which all data is placed (via GlobalWindows).
class	TimeWindow	A Window that represents a time interval from start (inclusive) to end (exclusive).

Uses of Window in org.apache.flink.streaming.runtime.operators.windowing

Classes in org.apache.flink.streaming.runtime.operators.windowing with type parameters of type Window

Modifier and Type	Class	Description
class	EvictingWindowOperator<K,IN,OUT,W extends Window>	A WindowOperator that also allows an Evictor to be used.
class	MergingWindowSet<W extends Window>	Utility for keeping track of merging Windows when using a MergingWindowAssigner in a WindowOperator.
class	WindowOperator<K,IN,ACC,OUT,W extends Window>	An operator that implements the logic for windowing based on a WindowAssigner and Trigger.
protected static class	WindowOperator.Timer<K,W extends Window>	Internal class for keeping track of in-flight timers.
class	WindowOperatorBuilder<T,K,W extends Window>	A builder for creating WindowOperators.

Fields in org.apache.flink.streaming.runtime.operators.windowing declared as Window

Modifier and Type	Field	Description
protected W	WindowOperator.AbstractPerWindowStateStore.window
protected W	WindowOperator.Context.window
protected W	WindowOperator.Timer.window
protected W	WindowOperator.WindowContext.window

Uses of Window in org.apache.flink.streaming.runtime.operators.windowing.functions

Classes in org.apache.flink.streaming.runtime.operators.windowing.functions with type parameters of type Window

Modifier and Type	Class	Description
class	InternalAggregateProcessAllWindowFunction<T,ACC,V,R,W extends Window>	Internal window function for wrapping a ProcessAllWindowFunction that takes an Iterable and an AggregateFunction.
class	InternalAggregateProcessWindowFunction<T,ACC,V,R,K,W extends Window>	Internal window function for wrapping a ProcessWindowFunction that takes an Iterable and an AggregateFunction.
class	InternalIterableAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping an AllWindowFunction that takes an Iterable when the window state also is an Iterable.
class	InternalIterableProcessAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping a ProcessAllWindowFunction that takes an Iterable when the window state also is an Iterable.
class	InternalIterableProcessWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a ProcessWindowFunction that takes an Iterable when the window state also is an Iterable.
class	InternalIterableWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a WindowFunction that takes an Iterable when the window state also is an Iterable.
class	InternalProcessAllWindowContext<IN,OUT,W extends Window>	Internal reusable context wrapper.
class	InternalProcessWindowContext<IN,OUT,KEY,W extends Window>	Internal reusable context wrapper.
class	InternalSingleValueAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping an AllWindowFunction that takes an Iterable when the window state is a single value.
class	InternalSingleValueProcessAllWindowFunction<IN,OUT,W extends Window>	Internal window function for wrapping a ProcessAllWindowFunction that takes an Iterable when the window state is a single value.
class	InternalSingleValueProcessWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a ProcessWindowFunction that takes an Iterable when the window state is a single value.
class	InternalSingleValueWindowFunction<IN,OUT,KEY,W extends Window>	Internal window function for wrapping a WindowFunction that takes an Iterable when the window state is a single value.
interface	InternalWindowFunction<IN,OUT,KEY,W extends Window>	Internal interface for functions that are evaluated over keyed (grouped) windows.