com.google.cloud.dataflow.sdk.transforms.windowing

Class GlobalWindow

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.windowing.WindowingFn<T,W>

com.google.cloud.dataflow.sdk.transforms.windowing.NonMergingWindowingFn<java.lang.Object,GlobalWindow.Window>

com.google.cloud.dataflow.sdk.transforms.windowing.GlobalWindow

All Implemented Interfaces:

java.io.Serializable

public class GlobalWindow
extends NonMergingWindowingFn<java.lang.Object,GlobalWindow.Window>

Default WindowingFn where all data is in the same bucket.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GlobalWindow.Window The default window into which all data is placed.

Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.WindowingFn

WindowingFn.AssignContext, WindowingFn.MergeContext

Constructor Summary

Constructors

Constructor and Description
GlobalWindow()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Collection<GlobalWindow.Window>	assignWindows(WindowingFn.AssignContext c) Given a timestamp and element, returns the set of windows into which it should be placed.
boolean	isCompatible(WindowingFn o) Returns whether this performs the same merging as the given WindowingFn.
Coder<GlobalWindow.Window>	windowCoder() Returns the Coder used for serializing the windows used by this windowingFn.

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.NonMergingWindowingFn

mergeWindows

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalWindow

public GlobalWindow()

Method Detail

assignWindows

public java.util.Collection<GlobalWindow.Window> assignWindows(WindowingFn.AssignContext c)

Description copied from class: WindowingFn

Given a timestamp and element, returns the set of windows into which it should be placed.

Specified by:

assignWindows in class WindowingFn<java.lang.Object,GlobalWindow.Window>

isCompatible

public boolean isCompatible(WindowingFn o)

Description copied from class: WindowingFn

Returns whether this performs the same merging as the given WindowingFn.

Specified by:

isCompatible in class WindowingFn<java.lang.Object,GlobalWindow.Window>

windowCoder

public Coder<GlobalWindow.Window> windowCoder()

Description copied from class: WindowingFn

Returns the Coder used for serializing the windows used by this windowingFn.

Specified by:

windowCoder in class WindowingFn<java.lang.Object,GlobalWindow.Window>