Package org.apache.beam.runners.twister2.utils

Class Twister2AssignContext<T,W extends BoundedWindow>

java.lang.Object

WindowFn<T,W>.org.apache.beam.sdk.transforms.windowing.WindowFn.AssignContext

org.apache.beam.runners.twister2.utils.Twister2AssignContext<T,W>

public class Twister2AssignContext<T,W extends BoundedWindow>
extends WindowFn<T,W>.AssignContext

doc.

Constructor Summary

Constructors

Constructor	Description
Twister2AssignContext(WindowFn<T,W> fn, WindowedValue<T> value)

Method Summary

Modifier and Type	Method	Description
T	element()	Returns the current element.
Instant	timestamp()	Returns the timestamp of the current element.
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

Twister2AssignContext

public Twister2AssignContext(WindowFn<T,W> fn,
 WindowedValue<T> value)

Method Details

element

public T element()

Description copied from class: WindowFn.AssignContext

Returns the current element.

Specified by:

element in class WindowFn<T,W extends BoundedWindow>.AssignContext

timestamp

public Instant timestamp()

Description copied from class: WindowFn.AssignContext

Returns the timestamp of the current element.

Specified by:

timestamp in class WindowFn<T,W extends BoundedWindow>.AssignContext

window

public BoundedWindow window()

Description copied from class: WindowFn.AssignContext

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

Specified by:

window in class WindowFn<T,W extends BoundedWindow>.AssignContext