Package org.apache.beam.sdk.transforms.windowing

Class MergeOverlappingIntervalWindows

java.lang.Object

org.apache.beam.sdk.transforms.windowing.MergeOverlappingIntervalWindows

@Internal
public class MergeOverlappingIntervalWindows
extends Object

For internal use only; no backwards compatibility guarantees.

A utility function for merging overlapping IntervalWindows.

Constructor Summary

Constructors

Constructor	Description
MergeOverlappingIntervalWindows()

Method Summary

Modifier and Type	Method	Description
static void	mergeWindows(WindowFn<?,IntervalWindow>.MergeContext c)	Merge overlapping IntervalWindows.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MergeOverlappingIntervalWindows

public MergeOverlappingIntervalWindows()

Method Details

mergeWindows

public static void mergeWindows(WindowFn<?,IntervalWindow>.MergeContext c)
                         throws Exception

Merge overlapping IntervalWindows.

Throws:

Exception