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

Class Window.Triggering<T>

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.windowing.Window.Triggering<T>

Enclosing class:

Window

public static class Window.Triggering<T>
extends Object

An incomplete Window transform that has a trigger specified but has an unspecified accumulation mode.

The currently available accumulation modes are:

• discardingFiredPanes(), which causes the elements in a pane to be discarded after the trigger fires and output is produced.

After specifying the accumulation mode the PTransform is complete and can be applied.

Method Summary

Modifier and Type	Method and Description
Window.Bound<T>	accumulatingFiredPanes() Returns a new Window PTransform that uses the registered WindowFn and Triggering behavior, and that accumulates elements in a pane after they are triggered.
Window.Bound<T>	discardingFiredPanes() Returns a new Window PTransform that uses the registered WindowFn and Triggering behavior, and that discards elements in a pane after they are triggered.

Methods inherited from class java.lang.Object

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

Method Detail

discardingFiredPanes

public Window.Bound<T> discardingFiredPanes()

Returns a new Window PTransform that uses the registered WindowFn and Triggering behavior, and that discards elements in a pane after they are triggered.

Does not modify this transform. The resulting PTransform is sufficiently specified to be applied, but more properties can still be specified.

accumulatingFiredPanes

@Experimental(value=TRIGGER)
public Window.Bound<T> accumulatingFiredPanes()

Returns a new Window PTransform that uses the registered WindowFn and Triggering behavior, and that accumulates elements in a pane after they are triggered.

Does not modify this transform. The resulting PTransform is sufficiently specified to be applied, but more properties can still be specified.