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).

Constructor Summary

Constructors

Constructor and Description
OnMergeContext()

Method Summary

Modifier and Type	Method and Description
abstract Trigger.OnMergeContext	forTrigger(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger) Create an OnMergeContext for executing the given trigger.
abstract Iterable<W>	oldWindows() The old windows that were merged.
abstract com.google.cloud.dataflow.sdk.util.ReduceFn.MergingStateContext	state() Returns the interface for accessing persistent state.
abstract Trigger.MergingTriggerInfo<W>	trigger() Returns the interface for accessing trigger info.

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

timers, window

Methods inherited from class java.lang.Object

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

Constructor Detail

OnMergeContext

public OnMergeContext()

Method Detail

oldWindows

public abstract Iterable<W> oldWindows()

The old windows that were merged.

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

state

public abstract com.google.cloud.dataflow.sdk.util.ReduceFn.MergingStateContext state()

Description copied from class: Trigger.TriggerContext

Returns the interface for accessing persistent state.

Specified by:

state in class Trigger.TriggerContext

trigger

public abstract Trigger.MergingTriggerInfo<W> trigger()

Description copied from class: Trigger.TriggerContext

Returns the interface for accessing trigger info.

Specified by:

trigger in class Trigger.TriggerContext