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

Class Trigger.OnElementEvent<W>

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.OnElementEvent<W>

Type Parameters:

W - BoundedWindow subclass used to represent the windows used by this OnElementEvent

Enclosing class:

Trigger<W extends BoundedWindow>

public static class Trigger.OnElementEvent<W>
extends java.lang.Object

Details about an invocation of Trigger.onElement(com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.TriggerContext<W>, com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.OnElementEvent<W>).

Constructor Summary

Constructors

Constructor and Description
Trigger.OnElementEvent(java.lang.Object value, Instant timestamp, W window, Trigger.WindowStatus status)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.Object	element() The element being handled by this call to Trigger.onElement(com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.TriggerContext<W>, com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.OnElementEvent<W>).
Instant	eventTimestamp() The event timestamp of the element being processed.
W	window() The window into which the element was assigned.
Trigger.WindowStatus	windowStatus() The status of the window to which the element was assigned.

Methods inherited from class java.lang.Object

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

Constructor Detail

Trigger.OnElementEvent

public Trigger.OnElementEvent(java.lang.Object value,
                      Instant timestamp,
                      W window,
                      Trigger.WindowStatus status)

Method Detail

element

public java.lang.Object element()

The element being handled by this call to Trigger.onElement(com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.TriggerContext<W>, com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.OnElementEvent<W>).

eventTimestamp

public Instant eventTimestamp()

The event timestamp of the element being processed.

window

public W window()

The window into which the element was assigned.

windowStatus

public Trigger.WindowStatus windowStatus()

The status of the window to which the element was assigned.