com.google.cloud.dataflow.sdk.util

Interface ReduceFn.Timers

Enclosing class:

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

public static interface ReduceFn.Timers

Interface for interacting with time.

Method Summary

Modifier and Type	Method and Description
org.joda.time.Instant	currentProcessingTime() Returns the current processing time.
void	deleteTimer(org.joda.time.Instant timestamp, TimeDomain timeDomain) Removes the timer set in this trigger context for the given window, timestmap and timeDomain.
void	setTimer(org.joda.time.Instant timestamp, TimeDomain timeDomain) Sets a timer to fire when the watermark or processing time is beyond the given timestamp.

Method Detail

setTimer

void setTimer(org.joda.time.Instant timestamp,
              TimeDomain timeDomain)

Sets a timer to fire when the watermark or processing time is beyond the given timestamp. Timers are not guaranteed to fire immediately, but will be delivered at some time afterwards.

As with ReduceFn.StateContext, timers are implicitly scoped to the current window. All timer firings for a window will be received, but the implementation should choose to ignore those that are not applicable.

Parameters:

timestamp - the time at which the trigger’s Trigger.onTimer(com.google.cloud.dataflow.sdk.transforms.windowing.Trigger<W>.OnTimerContext) callback should execute

timeDomain - the domain that the timestamp applies to

deleteTimer

void deleteTimer(org.joda.time.Instant timestamp,
                 TimeDomain timeDomain)

Removes the timer set in this trigger context for the given window, timestmap and timeDomain.

currentProcessingTime

org.joda.time.Instant currentProcessingTime()

Returns the current processing time.