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

Class InvalidWindows<W extends BoundedWindow>

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn<java.lang.Object,W>

com.google.cloud.dataflow.sdk.transforms.windowing.InvalidWindows<W>

Type Parameters:

W - window type

All Implemented Interfaces:

java.io.Serializable

public class InvalidWindows<W extends BoundedWindow>
extends WindowFn<java.lang.Object,W>

A WindowFn that represents an invalid pipeline state.

See Also:

Serialized Form

Nested Class Summary

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

WindowFn.AssignContext, WindowFn.MergeContext

Constructor Summary

Constructors

Constructor and Description
InvalidWindows(java.lang.String cause, WindowFn<?,W> originalWindowFn)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Collection<W>	assignWindows(WindowFn.AssignContext c) Given a timestamp and element, returns the set of windows into which it should be placed.
java.lang.String	getCause() Returns the reason that this WindowFn is invalid.
WindowFn<?,W>	getOriginalWindowFn() Returns the original windowFn that this InvalidWindows replaced.
boolean	isCompatible(WindowFn<?,?> other) InvalidWindows objects with the same originalWindowFn are compatible.
void	mergeWindows(WindowFn.MergeContext c) Does whatever merging of windows is necessary.
Coder<W>	windowCoder() Returns the Coder used for serializing the windows used by this windowFn.

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

getSideInputWindow

Methods inherited from class java.lang.Object

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

Constructor Detail

InvalidWindows

public InvalidWindows(java.lang.String cause,
              WindowFn<?,W> originalWindowFn)

Method Detail

getCause

public java.lang.String getCause()

Returns the reason that this WindowFn is invalid.

getOriginalWindowFn

public WindowFn<?,W> getOriginalWindowFn()

Returns the original windowFn that this InvalidWindows replaced.

assignWindows

public java.util.Collection<W> assignWindows(WindowFn.AssignContext c)

Description copied from class: WindowFn

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

Specified by:

assignWindows in class WindowFn<java.lang.Object,W extends BoundedWindow>

mergeWindows

public void mergeWindows(WindowFn.MergeContext c)

Description copied from class: WindowFn

Does whatever merging of windows is necessary.

See MergeOverlappingIntervalWindows.mergeWindows(com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn<?, com.google.cloud.dataflow.sdk.transforms.windowing.IntervalWindow>.MergeContext) for an example of how to override this method.

Specified by:

mergeWindows in class WindowFn<java.lang.Object,W extends BoundedWindow>

windowCoder

public Coder<W> windowCoder()

Description copied from class: WindowFn

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

Specified by:

windowCoder in class WindowFn<java.lang.Object,W extends BoundedWindow>

isCompatible

public boolean isCompatible(WindowFn<?,?> other)

InvalidWindows objects with the same originalWindowFn are compatible.

Specified by:

isCompatible in class WindowFn<java.lang.Object,W extends BoundedWindow>