Uses of Class
org.apache.flink.streaming.api.windowing.windows.TimeWindow
-
-
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 Description WindowedStream<T,KEY,TimeWindow>KeyedStream. timeWindow(Time size)Deprecated.Please useKeyedStream.window(WindowAssigner)with eitherTumblingEventTimeWindowsorTumblingProcessingTimeWindows.WindowedStream<T,KEY,TimeWindow>KeyedStream. timeWindow(Time size, Time slide)Deprecated.Please useKeyedStream.window(WindowAssigner)with eitherSlidingEventTimeWindowsorSlidingProcessingTimeWindows.AllWindowedStream<T,TimeWindow>DataStream. timeWindowAll(Time size)Deprecated.Please useDataStream.windowAll(WindowAssigner)with eitherTumblingEventTimeWindowsorTumblingProcessingTimeWindows.AllWindowedStream<T,TimeWindow>DataStream. timeWindowAll(Time size, Time slide)Deprecated.Please useDataStream.windowAll(WindowAssigner)with eitherSlidingEventTimeWindowsorSlidingProcessingTimeWindows. -
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 Description Collection<TimeWindow>DynamicEventTimeSessionWindows. assignWindows(T element, long timestamp, WindowAssigner.WindowAssignerContext context)Collection<TimeWindow>DynamicProcessingTimeSessionWindows. assignWindows(T element, long timestamp, WindowAssigner.WindowAssignerContext context)Collection<TimeWindow>EventTimeSessionWindows. assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)Collection<TimeWindow>ProcessingTimeSessionWindows. assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)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>TumblingProcessingTimeWindows. assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context)Trigger<T,TimeWindow>DynamicEventTimeSessionWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<T,TimeWindow>DynamicProcessingTimeSessionWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<Object,TimeWindow>EventTimeSessionWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<Object,TimeWindow>ProcessingTimeSessionWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<Object,TimeWindow>SlidingEventTimeWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<Object,TimeWindow>SlidingProcessingTimeWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<Object,TimeWindow>TumblingEventTimeWindows. getDefaultTrigger(StreamExecutionEnvironment env)Trigger<Object,TimeWindow>TumblingProcessingTimeWindows. getDefaultTrigger(StreamExecutionEnvironment env)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>DynamicEventTimeSessionWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>DynamicProcessingTimeSessionWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>EventTimeSessionWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>ProcessingTimeSessionWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>SlidingEventTimeWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>SlidingProcessingTimeWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>TumblingEventTimeWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>TumblingProcessingTimeWindows. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig) -
Uses of TimeWindow in org.apache.flink.streaming.api.windowing.triggers
-
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 Description TimeWindowTimeWindow.Serializer. copy(TimeWindow from)TimeWindowTimeWindow.Serializer. copy(TimeWindow from, TimeWindow reuse)TimeWindowTimeWindow. cover(TimeWindow other)Returns the minimal window covers both this window and the given window.TimeWindowTimeWindow.Serializer. createInstance()TimeWindowTimeWindow.Serializer. deserialize(org.apache.flink.core.memory.DataInputView source)TimeWindowTimeWindow.Serializer. deserialize(TimeWindow reuse, org.apache.flink.core.memory.DataInputView source)Methods in org.apache.flink.streaming.api.windowing.windows that return types with arguments of type TimeWindow Modifier and Type Method Description org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<TimeWindow>TimeWindow.Serializer. snapshotConfiguration()Methods in org.apache.flink.streaming.api.windowing.windows with parameters of type TimeWindow Modifier and Type Method Description TimeWindowTimeWindow.Serializer. copy(TimeWindow from)TimeWindowTimeWindow.Serializer. copy(TimeWindow from, TimeWindow reuse)TimeWindowTimeWindow. cover(TimeWindow other)Returns the minimal window covers both this window and the given window.TimeWindowTimeWindow.Serializer. deserialize(TimeWindow reuse, org.apache.flink.core.memory.DataInputView source)booleanTimeWindow. intersects(TimeWindow other)Returnstrueif this window intersects the given window or if this window is just after or before the given window.voidTimeWindow.Serializer. serialize(TimeWindow record, org.apache.flink.core.memory.DataOutputView target)Method parameters in org.apache.flink.streaming.api.windowing.windows with type arguments of type TimeWindow Modifier and Type Method Description static voidTimeWindow. mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c)Merge overlappingTimeWindows.static voidTimeWindow. mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c)Merge overlappingTimeWindows.
-