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

Class InvalidWindowingFn<W extends BoundedWindow>

java.lang.Object

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

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

Type Parameters:

W - window type

All Implemented Interfaces:

java.io.Serializable

public class InvalidWindowingFn<W extends BoundedWindow>
extends WindowingFn<java.lang.Object,W>

A WindowingFn 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.WindowingFn

WindowingFn.AssignContext, WindowingFn.MergeContext

Constructor Summary

Constructors

Constructor and Description
InvalidWindowingFn(java.lang.String cause, WindowingFn<?,W> originalWindowingFn)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Collection<W>	assignWindows(WindowingFn.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 WindowingFn is invalid.
WindowingFn<?,W>	getOriginalWindowingFn() Returns the original windowingFn that this InvalidWindowingFn replaced.
boolean	isCompatible(WindowingFn<?,?> other) InvalidWindowingFn objects with the same originalWindowingFn are compatible.
void	mergeWindows(WindowingFn.MergeContext c) Does whatever merging of windows is necessary.
Coder<W>	windowCoder() Returns the Coder used for serializing the windows used by this windowingFn.

Methods inherited from class java.lang.Object

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

Constructor Detail

InvalidWindowingFn

public InvalidWindowingFn(java.lang.String cause,
                  WindowingFn<?,W> originalWindowingFn)

Method Detail

getCause

public java.lang.String getCause()

Returns the reason that this WindowingFn is invalid.

getOriginalWindowingFn

public WindowingFn<?,W> getOriginalWindowingFn()

Returns the original windowingFn that this InvalidWindowingFn replaced.

assignWindows

public java.util.Collection<W> 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,W extends BoundedWindow>

mergeWindows

public void mergeWindows(WindowingFn.MergeContext c)

Description copied from class: WindowingFn

Does whatever merging of windows is necessary.

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

Specified by:

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

windowCoder

public Coder<W> 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,W extends BoundedWindow>

isCompatible

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

InvalidWindowingFn objects with the same originalWindowingFn are compatible.

Specified by:

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