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

Class Window.Unbound

java.lang.Object

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

Enclosing class:

Window

public static class Window.Unbound
extends Object

An incomplete Window transform, with unbound input/output type.

Before being applied, into(com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn<? super T, ?>) must be invoked to specify the WindowFn to invoke, which will also bind the input/output type of this PTransform.

Method Summary

Modifier and Type	Method and Description
<T> Window.Bound<T>	into(WindowFn<? super T,?> fn) Returns a new Window PTransform that's like this transform but that will use the given WindowFn, and that has its input and output types bound.
Window.Unbound	named(String name) Returns a new Window transform that's like this transform but with the specified name.

Methods inherited from class java.lang.Object

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

Method Detail

named

public Window.Unbound named(String name)

Returns a new Window transform that's like this transform but with the specified name. Does not modify this transform. The resulting transform is still incomplete.

See the discussion of Naming in ParDo for more explanation.

into

public <T> Window.Bound<T> into(WindowFn<? super T,?> fn)

Returns a new Window PTransform that's like this transform but that will use the given WindowFn, and that has its input and output types bound. Does not modify this transform. The resulting PTransform is sufficiently specified to be applied, but more properties can still be specified.