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

Class Trigger.OnElementContext

java.lang.Object

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

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

Enclosing class:

Trigger<W extends BoundedWindow>

public abstract class Trigger.OnElementContext
extends Trigger.TriggerContext

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

Constructor Summary

Constructors

Constructor and Description
OnElementContext(Object value, org.joda.time.Instant timestamp)

Method Summary

Modifier and Type	Method and Description
Object	element() The element being handled by this call to Trigger.onElement(com.google.cloud.dataflow.sdk.transforms.windowing.Trigger<W>.OnElementContext).
org.joda.time.Instant	eventTimestamp() The event timestamp of the element being processed.
abstract Trigger.OnElementContext	forTrigger(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Create an OnElementContext for executing the given trigger.

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.TriggerContext

areAllSubtriggersFinished, currentProcessingTime, deleteTimer, firstUnfinishedSubTrigger, isFinished, lookup, lookup, remove, resetTree, setFinished, setTimer, store, subTrigger, subTriggers, unfinishedSubTriggers, window

Methods inherited from class java.lang.Object

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

Constructor Detail

OnElementContext

public OnElementContext(Object value,
                        org.joda.time.Instant timestamp)

Method Detail

element

public Object element()

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

eventTimestamp

public org.joda.time.Instant eventTimestamp()

The event timestamp of the element being processed.

forTrigger

public abstract Trigger.OnElementContext forTrigger(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger)

Create an OnElementContext for executing the given trigger.

Specified by:

forTrigger in class Trigger.TriggerContext