org.apache.beam.sdk.transforms

Class DoFn.OnTimerContext

java.lang.Object

org.apache.beam.sdk.transforms.DoFn.WindowedContext

org.apache.beam.sdk.transforms.DoFn.OnTimerContext

Enclosing class:

DoFn<InputT,OutputT>

public abstract class DoFn.OnTimerContext
extends DoFn.WindowedContext

Information accessible when running a DoFn.OnTimer method.

Constructor Summary

Constructors

Constructor and Description
OnTimerContext()

Method Summary

Modifier and Type	Method and Description
abstract Instant	fireTimestamp() Returns the firing timestamp of the current timer.
abstract TimeDomain	timeDomain() Returns the time domain of the current timer.
abstract Instant	timestamp() Returns the output timestamp of the current timer.
abstract BoundedWindow	window() Returns the window in which the timer is firing.

Methods inherited from class org.apache.beam.sdk.transforms.DoFn.WindowedContext

getPipelineOptions, output, output, outputWindowedValue, outputWindowedValue, outputWithTimestamp, outputWithTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

OnTimerContext

public OnTimerContext()

Method Detail

timestamp

public abstract Instant timestamp()

Returns the output timestamp of the current timer.

fireTimestamp

public abstract Instant fireTimestamp()

Returns the firing timestamp of the current timer.

window

public abstract BoundedWindow window()

Returns the window in which the timer is firing.

timeDomain

public abstract TimeDomain timeDomain()

Returns the time domain of the current timer.