org.apache.beam.sdk.transforms.windowing

Class WindowFn.AssignContext

java.lang.Object

org.apache.beam.sdk.transforms.windowing.WindowFn.AssignContext

Direct Known Subclasses:

Twister2AssignContext

Enclosing class:

WindowFn<T,W extends BoundedWindow>

public abstract class WindowFn.AssignContext
extends java.lang.Object

Information available when running WindowFn.assignWindows(org.apache.beam.sdk.transforms.windowing.WindowFn<T, W>.AssignContext).

Constructor Summary

Constructors

Constructor and Description
AssignContext()

Method Summary

Modifier and Type	Method and Description
abstract T	element() Returns the current element.
abstract Instant	timestamp() Returns the timestamp of the current element.
abstract BoundedWindow	window() Returns the window of the current element prior to this WindowFn being called.

Methods inherited from class java.lang.Object

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

Constructor Detail

AssignContext

public AssignContext()

Method Detail

element

public abstract T element()

Returns the current element.

timestamp

public abstract Instant timestamp()

Returns the timestamp of the current element.

window

public abstract BoundedWindow window()

Returns the window of the current element prior to this WindowFn being called.