org.apache.beam.sdk.transforms

Class DoFn.OnWindowExpirationContext

java.lang.Object

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

org.apache.beam.sdk.transforms.DoFn.OnWindowExpirationContext

Enclosing class:

DoFn<InputT,OutputT>

public abstract class DoFn.OnWindowExpirationContext
extends DoFn.WindowedContext

Constructor Summary

Constructors

Constructor and Description
OnWindowExpirationContext()

Method Summary

Modifier and Type	Method and Description
abstract BoundedWindow	window() Returns the window in which the window expiration 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

OnWindowExpirationContext

public OnWindowExpirationContext()

Method Detail

window

@Pure
public abstract BoundedWindow window()

Returns the window in which the window expiration is firing.