Package org.apache.beam.sdk.transforms.windowing

Class Never

java.lang.Object

org.apache.beam.sdk.transforms.windowing.Never

public final class Never
extends Object

A Trigger which never fires.

Using this trigger will only produce output when the watermark passes the end of the window plus the allowed lateness.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Never.NeverTrigger	The actual trigger class for Never triggers.

Constructor Summary

Constructors

Constructor	Description
Never()

Method Summary

Modifier and Type	Method	Description
static Never.NeverTrigger	ever()	Returns a trigger which never fires.

Methods inherited from class java.lang.Object

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

Constructor Details

Never

public Never()

Method Details

ever

public static Never.NeverTrigger ever()

Returns a trigger which never fires. Output will be produced from the using GroupByKey when the BoundedWindow closes.