org.apache.beam.runners.twister2.utils

Class Twister2AssignContext<T,W extends BoundedWindow>

java.lang.Object

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.AssignContext

doc.

Constructor Summary

Constructors

Constructor and Description
Twister2AssignContext(WindowFn<T,W> fn, org.apache.beam.sdk.util.WindowedValue<T> value)

Method Summary

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

Twister2AssignContext

public Twister2AssignContext(WindowFn<T,W> fn,
                             org.apache.beam.sdk.util.WindowedValue<T> value)

Method Detail

element

public T element()

Description copied from class: WindowFn.AssignContext

Returns the current element.

Specified by:

element in class WindowFn.AssignContext

timestamp

public Instant timestamp()

Description copied from class: WindowFn.AssignContext

Returns the timestamp of the current element.

Specified by:

timestamp in class WindowFn.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.AssignContext