public class MergeOverlappingIntervalWindows
extends java.lang.Object
WindowingFn that merges overlapping IntervalWindows.| Constructor and Description |
|---|
MergeOverlappingIntervalWindows() |
| Modifier and Type | Method and Description |
|---|---|
static void |
mergeWindows(WindowingFn.MergeContext c)
Merge overlapping intervals.
|
public static void mergeWindows(WindowingFn.MergeContext c) throws java.lang.Exception
java.lang.Exception