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

Class Trigger.OnTimerEvent<W extends BoundedWindow>

java.lang.Object

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

Type Parameters:

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

Enclosing class:

Trigger<W extends BoundedWindow>

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

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

Constructor Summary

Constructors

Constructor and Description
Trigger.OnTimerEvent(Trigger.TriggerId<W> triggerId)

Method Summary

Methods

Modifier and Type	Method and Description
int	getChildIndex() Return the index of the child this trigger ID is for.
boolean	isForCurrentLayer() Return true if the timer event is for the current layer.
Trigger.TriggerId<W>	triggerId()
W	window()
Trigger.OnTimerEvent<W>	withoutOuterTrigger() Remove the outer layer from the path to the desired timer.

Methods inherited from class java.lang.Object

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

Constructor Detail

Trigger.OnTimerEvent

public Trigger.OnTimerEvent(Trigger.TriggerId<W> triggerId)

Method Detail

window

public W window()

triggerId

public Trigger.TriggerId<W> triggerId()

withoutOuterTrigger

public Trigger.OnTimerEvent<W> withoutOuterTrigger()

Remove the outer layer from the path to the desired timer. This produces an OnTimerEvent suitable for passing to a subtrigger.

getChildIndex

public int getChildIndex()

Return the index of the child this trigger ID is for.

isForCurrentLayer

public boolean isForCurrentLayer()

Return true if the timer event is for the current layer.