org.apache.beam.runners.twister2.utils

Class Twister2AssignContext<IT,W extends BoundedWindow>

java.lang.Object

<any>.AssignContext

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

public class Twister2AssignContext<IT,W extends BoundedWindow>
extends <any>.AssignContext

doc.

Constructor Summary

Constructors

Constructor and Description
Twister2AssignContext(<any> fn, <any> value)

Method Summary

Modifier and Type	Method and Description
IT	element()
Instant	timestamp()
BoundedWindow	window()

Methods inherited from class java.lang.Object

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

Constructor Detail

Twister2AssignContext

public Twister2AssignContext(<any> fn,
                             <any> value)

Method Detail

element

public IT element()

timestamp

public Instant timestamp()

window

public BoundedWindow window()