Uses of Class
org.apache.flink.table.runtime.operators.window.TimeWindow
-
-
Uses of TimeWindow in org.apache.flink.table.runtime.operators.window
Methods in org.apache.flink.table.runtime.operators.window 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)static TimeWindowTimeWindow. of(long start, long end)Methods in org.apache.flink.table.runtime.operators.window 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.table.runtime.operators.window 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.voidTimeWindow.Serializer. serialize(TimeWindow record, org.apache.flink.core.memory.DataOutputView target)Constructor parameters in org.apache.flink.table.runtime.operators.window with type arguments of type TimeWindow Constructor Description WindowTableFunctionOperator(WindowAssigner<TimeWindow> windowAssigner, int rowtimeIndex, java.time.ZoneId shiftTimeZone) -
Uses of TimeWindow in org.apache.flink.table.runtime.operators.window.assigners
Methods in org.apache.flink.table.runtime.operators.window.assigners that return TimeWindow Modifier and Type Method Description TimeWindowCumulativeWindowAssigner. assignPane(Object element, long timestamp)TimeWindowSlidingWindowAssigner. assignPane(Object element, long timestamp)TimeWindowCumulativeWindowAssigner. getLastWindow(TimeWindow pane)TimeWindowSlidingWindowAssigner. getLastWindow(TimeWindow pane)Methods in org.apache.flink.table.runtime.operators.window.assigners that return types with arguments of type TimeWindow Modifier and Type Method Description Collection<TimeWindow>CumulativeWindowAssigner. assignWindows(org.apache.flink.table.data.RowData element, long timestamp)Collection<TimeWindow>SessionWindowAssigner. assignWindows(org.apache.flink.table.data.RowData element, long timestamp)Collection<TimeWindow>SlidingWindowAssigner. assignWindows(org.apache.flink.table.data.RowData element, long timestamp)Collection<TimeWindow>TumblingWindowAssigner. assignWindows(org.apache.flink.table.data.RowData element, long timestamp)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>CumulativeWindowAssigner. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>SessionWindowAssigner. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>SlidingWindowAssigner. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>TumblingWindowAssigner. getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)Iterable<TimeWindow>CumulativeWindowAssigner. splitIntoPanes(TimeWindow window)Iterable<TimeWindow>SlidingWindowAssigner. splitIntoPanes(TimeWindow window)Methods in org.apache.flink.table.runtime.operators.window.assigners with parameters of type TimeWindow Modifier and Type Method Description TimeWindowCumulativeWindowAssigner. getLastWindow(TimeWindow pane)TimeWindowSlidingWindowAssigner. getLastWindow(TimeWindow pane)voidSessionWindowAssigner. mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergingWindowAssigner.MergeCallback<TimeWindow> callback)Iterable<TimeWindow>CumulativeWindowAssigner. splitIntoPanes(TimeWindow window)Iterable<TimeWindow>SlidingWindowAssigner. splitIntoPanes(TimeWindow window)Method parameters in org.apache.flink.table.runtime.operators.window.assigners with type arguments of type TimeWindow Modifier and Type Method Description voidSessionWindowAssigner. mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergingWindowAssigner.MergeCallback<TimeWindow> callback)voidSessionWindowAssigner. mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergingWindowAssigner.MergeCallback<TimeWindow> callback) -
Uses of TimeWindow in org.apache.flink.table.runtime.operators.window.grouping
Methods in org.apache.flink.table.runtime.operators.window.grouping that return TimeWindow Modifier and Type Method Description TimeWindowWindowsGrouping. getTriggerWindow()
-