Package | Description |
---|---|
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.api.windowing.windows |
Modifier and Type | Method and Description |
---|---|
void |
ProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
void |
DynamicEventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
void |
EventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
void |
DynamicProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
abstract void |
MergingWindowAssigner.mergeWindows(Collection<W> windows,
MergingWindowAssigner.MergeCallback<W> callback)
Determines which windows (if any) should be merged.
|
Modifier and Type | Method and Description |
---|---|
static void |
TimeWindow.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.