Class NonMergingWindowFn<T,W extends BoundedWindow>
- java.lang.Object
-
- org.apache.beam.sdk.transforms.windowing.WindowFn<T,W>
-
- org.apache.beam.sdk.transforms.windowing.NonMergingWindowFn<T,W>
-
- Type Parameters:
T
- type of elements being windowedW
-BoundedWindow
subclass used to represent the windows used by thisWindowFn
- All Implemented Interfaces:
java.io.Serializable
,HasDisplayData
- Direct Known Subclasses:
GlobalWindows
,IdentityWindowFn
,PartitioningWindowFn
,SlidingWindows
public abstract class NonMergingWindowFn<T,W extends BoundedWindow> extends WindowFn<T,W>
Abstract base class forWindowFns
that do not merge windows.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.windowing.WindowFn
WindowFn.AssignContext, WindowFn.MergeContext
-
-
Constructor Summary
Constructors Constructor Description NonMergingWindowFn()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isNonMerging()
Returns true if thisWindowFn
never needs to merge any windows.void
mergeWindows(WindowFn.MergeContext c)
Does whatever merging of windows is necessary.-
Methods inherited from class org.apache.beam.sdk.transforms.windowing.WindowFn
assignsToOneWindow, assignWindows, getDefaultWindowMappingFn, getWindowTypeDescriptor, isCompatible, populateDisplayData, verifyCompatibility, windowCoder
-
-
-
-
Method Detail
-
mergeWindows
public final void mergeWindows(WindowFn.MergeContext c)
Description copied from class:WindowFn
Does whatever merging of windows is necessary.See
MergeOverlappingIntervalWindows.mergeWindows(org.apache.beam.sdk.transforms.windowing.WindowFn.MergeContext)
for an example of how to override this method.- Specified by:
mergeWindows
in classWindowFn<T,W extends BoundedWindow>
-
isNonMerging
public final boolean isNonMerging()
Description copied from class:WindowFn
Returns true if thisWindowFn
never needs to merge any windows.- Overrides:
isNonMerging
in classWindowFn<T,W extends BoundedWindow>
-
-