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

Class Trigger.OnTimerContext

java.lang.Object

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

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

Enclosing class:

Trigger<W extends BoundedWindow>

public abstract class Trigger.OnTimerContext
extends Trigger.TriggerContext

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

Field Summary

Fields

Modifier and Type	Field and Description
protected Trigger.TriggerId<W>	destinationId

Constructor Summary

Constructors

Constructor and Description
OnTimerContext(Trigger.TriggerId<W> destinationId)

Method Summary

Modifier and Type	Method and Description
abstract Trigger.OnTimerContext	forTrigger(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Create an OnTimerContext for executing the given trigger.
int	getDestinationIndex()
abstract boolean	isDestination() Returns true if the given trigger index corresponds to the current trigger.
abstract com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W>	nextStepTowardsDestination() Returns the sub-trigger of the current trigger that is the next step towards the destination.

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

Field Detail

destinationId

protected final Trigger.TriggerId<W extends BoundedWindow> destinationId

Constructor Detail

OnTimerContext

public OnTimerContext(Trigger.TriggerId<W> destinationId)

Method Detail

getDestinationIndex

public int getDestinationIndex()

nextStepTowardsDestination

public abstract com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> nextStepTowardsDestination()

Returns the sub-trigger of the current trigger that is the next step towards the destination.

isDestination

public abstract boolean isDestination()

Returns true if the given trigger index corresponds to the current trigger.

forTrigger

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

Create an OnTimerContext for executing the given trigger.

Specified by:

forTrigger in class Trigger.TriggerContext