Package 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 Description static class
ValueInSingleWindow.Coder<T>
A coder forValueInSingleWindow
.
-
Constructor Summary
Constructors Constructor Description ValueInSingleWindow()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract @Nullable 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 thisValueInSingleWindow
in its window.abstract org.joda.time.Instant
getTimestamp()
Returns the timestamp of thisValueInSingleWindow
.T
getValue()
Returns the value of thisValueInSingleWindow
.abstract BoundedWindow
getWindow()
Returns the window of thisValueInSingleWindow
.static <T> ValueInSingleWindow<T>
of(T value, org.joda.time.Instant timestamp, BoundedWindow window, PaneInfo paneInfo)
-
-
-
Method Detail
-
getValue
public T getValue()
Returns the value of thisValueInSingleWindow
.
-
getNullableValue
protected abstract @Nullable T getNullableValue()
Workaround for autovalue code generation, which does not allow type variables to be instantiated with nullable actual parameters.
-
getTimestamp
public abstract org.joda.time.Instant getTimestamp()
Returns the timestamp of thisValueInSingleWindow
.
-
getWindow
public abstract BoundedWindow getWindow()
Returns the window of thisValueInSingleWindow
.
-
getPane
public abstract PaneInfo getPane()
Returns the pane of thisValueInSingleWindow
in its window.
-
of
public static <T> ValueInSingleWindow<T> of(T value, org.joda.time.Instant timestamp, BoundedWindow window, PaneInfo paneInfo)
-
-