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

Packages that use TimeWindow

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.windowing.assigners
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.api.windowing.windows

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

Methods in org.apache.flink.streaming.api.datastream that return types with arguments of type TimeWindow

Modifier and Type	Method and Description
WindowedStream<T,KEY,TimeWindow>	KeyedStream.timeWindow(Time size) Deprecated. Please use KeyedStream.window(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows. For more information, see the deprecation notice on TimeCharacteristic
WindowedStream<T,KEY,TimeWindow>	KeyedStream.timeWindow(Time size, Time slide) Deprecated. Please use KeyedStream.window(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows. For more information, see the deprecation notice on TimeCharacteristic
AllWindowedStream<T,TimeWindow>	DataStream.timeWindowAll(Time size) Deprecated. Please use DataStream.windowAll(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows. For more information, see the deprecation notice on TimeCharacteristic
AllWindowedStream<T,TimeWindow>	DataStream.timeWindowAll(Time size, Time slide) Deprecated. Please use DataStream.windowAll(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows. For more information, see the deprecation notice on TimeCharacteristic

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

Methods in org.apache.flink.streaming.api.windowing.assigners that return types with arguments of type TimeWindow

Modifier and Type	Method and Description
Collection<TimeWindow>	SlidingEventTimeWindows.assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	SlidingProcessingTimeWindows.assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	TumblingEventTimeWindows.assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	EventTimeSessionWindows.assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	TumblingProcessingTimeWindows.assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	ProcessingTimeSessionWindows.assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	DynamicEventTimeSessionWindows.assignWindows(T element, long timestamp, WindowAssigner.WindowAssignerContext context)
Collection<TimeWindow>	DynamicProcessingTimeSessionWindows.assignWindows(T element, long timestamp, WindowAssigner.WindowAssignerContext context)
Trigger<T,TimeWindow>	DynamicEventTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	SlidingEventTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	SlidingProcessingTimeWindows.getDefaultTrigger()
Trigger<T,TimeWindow>	DynamicProcessingTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	TumblingEventTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	EventTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	TumblingProcessingTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	ProcessingTimeSessionWindows.getDefaultTrigger()
Trigger<T,TimeWindow>	DynamicEventTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	SlidingEventTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	SlidingProcessingTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<T,TimeWindow>	DynamicProcessingTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	TumblingEventTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	EventTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	TumblingProcessingTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	ProcessingTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
TypeSerializer<TimeWindow>	DynamicEventTimeSessionWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	SlidingEventTimeWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	SlidingProcessingTimeWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	DynamicProcessingTimeSessionWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	TumblingEventTimeWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	EventTimeSessionWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	TumblingProcessingTimeWindows.getWindowSerializer(ExecutionConfig executionConfig)
TypeSerializer<TimeWindow>	ProcessingTimeSessionWindows.getWindowSerializer(ExecutionConfig executionConfig)

Method parameters in org.apache.flink.streaming.api.windowing.assigners with type arguments of type TimeWindow

Modifier and Type	Method and Description
void	DynamicEventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	DynamicEventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	DynamicProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	DynamicProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	EventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	EventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	ProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
void	ProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.

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

Methods in org.apache.flink.streaming.api.windowing.triggers with parameters of type TimeWindow

Modifier and Type	Method and Description
void	ProcessingTimeTrigger.clear(TimeWindow window, Trigger.TriggerContext ctx)
void	EventTimeTrigger.clear(TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	ProcessingTimeTrigger.onElement(Object element, long timestamp, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	EventTimeTrigger.onElement(Object element, long timestamp, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	ProcessingTimeTrigger.onEventTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	EventTimeTrigger.onEventTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
void	ProcessingTimeTrigger.onMerge(TimeWindow window, Trigger.OnMergeContext ctx)
void	EventTimeTrigger.onMerge(TimeWindow window, Trigger.OnMergeContext ctx)
TriggerResult	ProcessingTimeTrigger.onProcessingTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	EventTimeTrigger.onProcessingTime(long time, TimeWindow window, Trigger.TriggerContext ctx)

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

Methods in org.apache.flink.streaming.api.windowing.windows that return TimeWindow

Modifier and Type	Method and Description
TimeWindow	TimeWindow.Serializer.copy(TimeWindow from)
TimeWindow	TimeWindow.Serializer.copy(TimeWindow from, TimeWindow reuse)
TimeWindow	TimeWindow.cover(TimeWindow other) Returns the minimal window covers both this window and the given window.
TimeWindow	TimeWindow.Serializer.createInstance()
TimeWindow	TimeWindow.Serializer.deserialize(DataInputView source)
TimeWindow	TimeWindow.Serializer.deserialize(TimeWindow reuse, DataInputView source)

Methods in org.apache.flink.streaming.api.windowing.windows that return types with arguments of type TimeWindow

Modifier and Type	Method and Description
TypeSerializerSnapshot<TimeWindow>	TimeWindow.Serializer.snapshotConfiguration()

Methods in org.apache.flink.streaming.api.windowing.windows with parameters of type TimeWindow

Modifier and Type	Method and Description
TimeWindow	TimeWindow.Serializer.copy(TimeWindow from)
TimeWindow	TimeWindow.Serializer.copy(TimeWindow from, TimeWindow reuse)
TimeWindow	TimeWindow.cover(TimeWindow other) Returns the minimal window covers both this window and the given window.
TimeWindow	TimeWindow.Serializer.deserialize(TimeWindow reuse, DataInputView source)
boolean	TimeWindow.intersects(TimeWindow other) Returns true if this window intersects the given window or if this window is just after or before the given window.
void	TimeWindow.Serializer.serialize(TimeWindow record, DataOutputView target)

Method parameters in org.apache.flink.streaming.api.windowing.windows with type arguments of type TimeWindow

Modifier and Type	Method and Description
static void	TimeWindow.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
static void	TimeWindow.mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.