Package org.apache.beam.sdk.transforms

Class DoFn.OnTimerContext

java.lang.Object

DoFn<InputT,OutputT>.org.apache.beam.sdk.transforms.DoFn.WindowedContext

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

Enclosing class:

DoFn<InputT extends @Nullable Object,OutputT extends @Nullable Object>

public abstract class DoFn.OnTimerContext
extends DoFn<InputT,OutputT>.WindowedContext

Information accessible when running a DoFn.OnTimer method.

Constructor Summary

Constructors

Constructor	Description
OnTimerContext()

Method Summary

Modifier and Type	Method	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 Details

OnTimerContext

public OnTimerContext()

Method Details

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.