org.apache.beam.sdk.transforms.windowing

Class Never

java.lang.Object

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

public final class Never
extends java.lang.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 and Description
static class	Never.NeverTrigger The actual trigger class for Never triggers.

Constructor Summary

Constructors

Constructor and Description
Never()

Method Summary

Modifier and Type	Method and 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 Detail

Never

public Never()

Method Detail

ever

public static Never.NeverTrigger ever()

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