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

Class Trigger.OnMergeContext

java.lang.Object

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

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

Enclosing class:

Trigger<W extends BoundedWindow>

public abstract class Trigger.OnMergeContext
extends Trigger.TriggerContext

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

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<W,BitSet>	finishedSets

Constructor Summary

Constructors

Constructor and Description
OnMergeContext(Iterable<W> oldWindows, Map<W,BitSet> finishedSets)

Method Summary

Modifier and Type	Method and Description
abstract boolean	finishedInAnyMergingWindow() Return true if the trigger is finished in any window being merged.
abstract Trigger.OnMergeContext	forTrigger(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Create an OnMergeContext for executing the given trigger.
abstract Iterable<W>	getFinishedMergingWindows() Return the merging windows in which the trigger is finished.
Iterable<W>	oldWindows() The old windows that were merged.

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

finishedSets

protected final Map<W extends BoundedWindow,BitSet> finishedSets

Constructor Detail

OnMergeContext

public OnMergeContext(Iterable<W> oldWindows,
                      Map<W,BitSet> finishedSets)

Method Detail

oldWindows

public Iterable<W> oldWindows()

The old windows that were merged.

finishedInAnyMergingWindow

public abstract boolean finishedInAnyMergingWindow()

Return true if the trigger is finished in any window being merged.

getFinishedMergingWindows

public abstract Iterable<W> getFinishedMergingWindows()

Return the merging windows in which the trigger is finished.

forTrigger

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

Create an OnMergeContext for executing the given trigger.

Specified by:

forTrigger in class Trigger.TriggerContext