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 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 for ValueInSingleWindow.

Constructor Summary

Constructors

Constructor	Description
ValueInSingleWindow()

Method Summary

Modifier and Type	Method	Description
abstract CausedByDrain	getCausedByDrain()
abstract @Nullable String	getCurrentRecordId()
abstract @Nullable Long	getCurrentRecordOffset()
protected abstract @Nullable T	getNullableValue()	Workaround for autovalue code generation, which does not allow type variables to be instantiated with nullable actual parameters.
abstract @Nullable Context	getOpenTelemetryContext()
abstract PaneInfo	getPaneInfo()	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 ValueKind	getValueKind()
abstract BoundedWindow	getWindow()	Returns the window of this ValueInSingleWindow.
static <T> ValueInSingleWindow<T>	of(T value, Instant timestamp, BoundedWindow window, PaneInfo paneInfo)
static <T> ValueInSingleWindow<T>	of(T value, Instant timestamp, BoundedWindow window, PaneInfo paneInfo, @Nullable String currentRecordId, @Nullable Long currentRecordOffset, CausedByDrain causedByDrain, @Nullable Context openTelemetryContext)
static <T> ValueInSingleWindow<T>	of(T value, Instant timestamp, BoundedWindow window, PaneInfo paneInfo, @Nullable String currentRecordId, @Nullable Long currentRecordOffset, CausedByDrain causedByDrain, @Nullable Context openTelemetryContext, ValueKind valueKind)

Methods inherited from class java.lang.Object

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

Constructor Details

ValueInSingleWindow

public ValueInSingleWindow()

Method Details

getValue

public T getValue()

Returns the value of this ValueInSingleWindow.

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 Instant getTimestamp()

Returns the timestamp of this ValueInSingleWindow.

getWindow

public abstract BoundedWindow getWindow()

Returns the window of this ValueInSingleWindow.

getPaneInfo

public abstract PaneInfo getPaneInfo()

Returns the pane of this ValueInSingleWindow in its window.

getCurrentRecordId

public abstract @Nullable String getCurrentRecordId()

getCurrentRecordOffset

public abstract @Nullable Long getCurrentRecordOffset()

getCausedByDrain

public abstract CausedByDrain getCausedByDrain()

getOpenTelemetryContext

public abstract @Nullable Context getOpenTelemetryContext()

getValueKind

public abstract ValueKind getValueKind()

of

public static <T> ValueInSingleWindow<T> of(T value,
 Instant timestamp,
 BoundedWindow window,
 PaneInfo paneInfo,
 @Nullable String currentRecordId,
 @Nullable Long currentRecordOffset,
 CausedByDrain causedByDrain,
 @Nullable Context openTelemetryContext)

of

public static <T> ValueInSingleWindow<T> of(T value,
 Instant timestamp,
 BoundedWindow window,
 PaneInfo paneInfo,
 @Nullable String currentRecordId,
 @Nullable Long currentRecordOffset,
 CausedByDrain causedByDrain,
 @Nullable Context openTelemetryContext,
 ValueKind valueKind)

of

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