org.apache.beam.sdk.transforms.windowing

Class MergeOverlappingIntervalWindows

java.lang.Object

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

@Internal
public class MergeOverlappingIntervalWindows
extends java.lang.Object

For internal use only; no backwards compatibility guarantees.

A utility function for merging overlapping IntervalWindows.

Constructor Summary

Constructors

Constructor and Description
MergeOverlappingIntervalWindows()

Method Summary

Modifier and Type	Method and Description
static void	mergeWindows(WindowFn.MergeContext c) Merge overlapping IntervalWindows.

Methods inherited from class java.lang.Object

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

Constructor Detail

MergeOverlappingIntervalWindows

public MergeOverlappingIntervalWindows()

Method Detail

mergeWindows

public static void mergeWindows(WindowFn.MergeContext c)
                         throws java.lang.Exception

Merge overlapping IntervalWindows.

Throws:

java.lang.Exception