Package 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 Object

Information available when running WindowFn.assignWindows(org.apache.beam.sdk.transforms.windowing.WindowFn.AssignContext).

Constructor Summary

Constructors

Constructor	Description
AssignContext()

Method Summary

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

AssignContext

public AssignContext()

Method Details

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.