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) |
static TimeWindow |
TimeWindow.of(long start,
long end) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<TimeWindow> |
TimeWindow.Serializer.snapshotConfiguration() |
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. |
void |
TimeWindow.Serializer.serialize(TimeWindow record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
TimeWindow |
SlidingWindowAssigner.assignPane(Object element,
long timestamp) |
TimeWindow |
CumulativeWindowAssigner.assignPane(Object element,
long timestamp) |
TimeWindow |
SlidingWindowAssigner.getLastWindow(TimeWindow pane) |
TimeWindow |
CumulativeWindowAssigner.getLastWindow(TimeWindow pane) |
Modifier and Type | Method and Description |
---|---|
Collection<TimeWindow> |
SlidingWindowAssigner.assignWindows(RowData element,
long timestamp) |
Collection<TimeWindow> |
SessionWindowAssigner.assignWindows(RowData element,
long timestamp) |
Collection<TimeWindow> |
CumulativeWindowAssigner.assignWindows(RowData element,
long timestamp) |
Collection<TimeWindow> |
TumblingWindowAssigner.assignWindows(RowData element,
long timestamp) |
TypeSerializer<TimeWindow> |
SlidingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
SessionWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
CumulativeWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
TumblingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
Iterable<TimeWindow> |
SlidingWindowAssigner.splitIntoPanes(TimeWindow window) |
Iterable<TimeWindow> |
CumulativeWindowAssigner.splitIntoPanes(TimeWindow window) |
Modifier and Type | Method and Description |
---|---|
TimeWindow |
SlidingWindowAssigner.getLastWindow(TimeWindow pane) |
TimeWindow |
CumulativeWindowAssigner.getLastWindow(TimeWindow pane) |
void |
SessionWindowAssigner.mergeWindows(TimeWindow newWindow,
NavigableSet<TimeWindow> sortedWindows,
MergingWindowAssigner.MergeCallback<TimeWindow> callback) |
Iterable<TimeWindow> |
SlidingWindowAssigner.splitIntoPanes(TimeWindow window) |
Iterable<TimeWindow> |
CumulativeWindowAssigner.splitIntoPanes(TimeWindow window) |
Modifier and Type | Method and Description |
---|---|
void |
SessionWindowAssigner.mergeWindows(TimeWindow newWindow,
NavigableSet<TimeWindow> sortedWindows,
MergingWindowAssigner.MergeCallback<TimeWindow> callback) |
void |
SessionWindowAssigner.mergeWindows(TimeWindow newWindow,
NavigableSet<TimeWindow> sortedWindows,
MergingWindowAssigner.MergeCallback<TimeWindow> callback) |
Modifier and Type | Method and Description |
---|---|
TimeWindow |
WindowsGrouping.getTriggerWindow() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.