| 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.
|
void setTimer(org.joda.time.Instant timestamp,
TimeDomain timeDomain)
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.
timestamp - the time at which the trigger’s Trigger.onTimer(com.google.cloud.dataflow.sdk.transforms.windowing.Trigger<W>.OnTimerContext) callback should
executetimeDomain - the domain that the timestamp applies tovoid deleteTimer(org.joda.time.Instant timestamp,
TimeDomain timeDomain)
window, timestmap
and timeDomain.org.joda.time.Instant currentProcessingTime()