org.apache.beam.sdk.values

Class ValueInSingleWindow<T>

java.lang.Object

org.apache.beam.sdk.values.ValueInSingleWindow<T>

Type Parameters:

T - the type of the value

@Internal
public abstract class ValueInSingleWindow<T>
extends java.lang.Object

An immutable tuple of value, timestamp, window, and pane.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ValueInSingleWindow.Coder<T> A coder for ValueInSingleWindow.

Constructor Summary

Constructors

Constructor and Description
ValueInSingleWindow()

Method Summary

Modifier and Type	Method and Description
protected abstract T	getNullableValue() Workaround for autovalue code generation, which does not allow type variables to be instantiated with nullable actual parameters.
abstract PaneInfo	getPane() Returns the pane of this ValueInSingleWindow in its window.
abstract Instant	getTimestamp() Returns the timestamp of this ValueInSingleWindow.
T	getValue() Returns the value of this ValueInSingleWindow.
abstract BoundedWindow	getWindow() Returns the window of this ValueInSingleWindow.
static <T> ValueInSingleWindow<T>	of(T value, Instant timestamp, BoundedWindow window, PaneInfo paneInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

ValueInSingleWindow

public ValueInSingleWindow()

Method Detail

getValue

public T getValue()

Returns the value of this ValueInSingleWindow.

getNullableValue

protected abstract T getNullableValue()

Workaround for autovalue code generation, which does not allow type variables to be instantiated with nullable actual parameters.

getTimestamp

public abstract Instant getTimestamp()

Returns the timestamp of this ValueInSingleWindow.

getWindow

public abstract BoundedWindow getWindow()

Returns the window of this ValueInSingleWindow.

getPane

public abstract PaneInfo getPane()

Returns the pane of this ValueInSingleWindow in its window.

of

public static <T> ValueInSingleWindow<T> of(T value,
                                            Instant timestamp,
                                            BoundedWindow window,
                                            PaneInfo paneInfo)