com.google.cloud.dataflow.sdk.util

Class ReduceFn.OnTriggerContext

java.lang.Object

com.google.cloud.dataflow.sdk.util.ReduceFn.Context

com.google.cloud.dataflow.sdk.util.ReduceFn.OnTriggerContext

Enclosing class:

ReduceFn<K,InputT,OutputT,W extends BoundedWindow>

public abstract class ReduceFn.OnTriggerContext
extends ReduceFn.Context

Information accessible within ReduceFn.onTrigger(com.google.cloud.dataflow.sdk.util.ReduceFn<K, InputT, OutputT, W>.OnTriggerContext).

Constructor Summary

Constructors

Constructor and Description
OnTriggerContext()

Method Summary

Modifier and Type	Method and Description
abstract void	output(OutputT value) Output the given value in the current window.
abstract PaneInfo	paneInfo() Returns the PaneInfo for the trigger firing being processed.

Methods inherited from class com.google.cloud.dataflow.sdk.util.ReduceFn.Context

key, state, timers, window, windowingStrategy

Methods inherited from class java.lang.Object

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

Constructor Detail

OnTriggerContext

public OnTriggerContext()

Method Detail

paneInfo

public abstract PaneInfo paneInfo()

Returns the PaneInfo for the trigger firing being processed.

output

public abstract void output(OutputT value)

Output the given value in the current window.