Package org.apache.beam.sdk.transforms

Class DoFn.OnWindowExpirationContext

java.lang.Object

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

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

Enclosing class:

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

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

Constructor Summary

Constructors

Constructor	Description
OnWindowExpirationContext()

Method Summary

Modifier and Type	Method	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, outputWindowedValue, outputWindowedValue, outputWithTimestamp, outputWithTimestamp

Methods inherited from class java.lang.Object

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

Constructor Details

OnWindowExpirationContext

public OnWindowExpirationContext()

Method Details

window

@Pure
public abstract BoundedWindow window()

Returns the window in which the window expiration is firing.