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

Class Trigger.OnMergeEvent<W extends BoundedWindow>

java.lang.Object

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

Type Parameters:

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

Enclosing class:

Trigger<W extends BoundedWindow>

public static class Trigger.OnMergeEvent<W extends BoundedWindow>
extends Object

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

Constructor Summary

Constructors

Constructor and Description
Trigger.OnMergeEvent(Iterable<W> oldWindows, W newWindow, Map<W,BitSet> finishedSets)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	finishedInAllMergingWindows(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Return true if the trigger is finished in all the windows being merged.
boolean	finishedInAnyMergingWindow(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Return true if the trigger is finished in any window being merged.
Iterable<W>	getFinishedMergingWindows(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Return the merging windows in which the trigger is finished.
W	newWindow() The new window produced by merging the oldWindows().
Iterable<W>	oldWindows() The old windows that were merged.

Methods inherited from class java.lang.Object

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

Constructor Detail

Trigger.OnMergeEvent

public Trigger.OnMergeEvent(Iterable<W> oldWindows,
                    W newWindow,
                    Map<W,BitSet> finishedSets)

Method Detail

oldWindows

public Iterable<W> oldWindows()

The old windows that were merged.

newWindow

public W newWindow()

The new window produced by merging the oldWindows().

finishedInAnyMergingWindow

public boolean finishedInAnyMergingWindow(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger)

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

finishedInAllMergingWindows

public boolean finishedInAllMergingWindows(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger)

Return true if the trigger is finished in all the windows being merged.

getFinishedMergingWindows

public Iterable<W> getFinishedMergingWindows(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger)

Return the merging windows in which the trigger is finished.