Package org.apache.beam.sdk.values

Class FailsafeValueInSingleWindow<T,ErrorT>

java.lang.Object

org.apache.beam.sdk.values.FailsafeValueInSingleWindow<T,ErrorT>

Type Parameters:

T - the type of the value

@Internal
public abstract class FailsafeValueInSingleWindow<T,ErrorT>
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FailsafeValueInSingleWindow.Coder<T,ErrorT>	A coder for FailsafeValueInSingleWindow.

Constructor Summary

Constructors

Constructor	Description
FailsafeValueInSingleWindow()

Method Summary

Modifier and Type	Method	Description
abstract ErrorT	getFailsafeValue()	Returns the failsafe value of this FailsafeValueInSingleWindow.
abstract PaneInfo	getPaneInfo()	Returns the pane of this FailsafeValueInSingleWindow in its window.
abstract Instant	getTimestamp()	Returns the timestamp of this FailsafeValueInSingleWindow.
abstract T	getValue()	Returns the value of this FailsafeValueInSingleWindow.
abstract BoundedWindow	getWindow()	Returns the window of this FailsafeValueInSingleWindow.
static <T, ErrorT> FailsafeValueInSingleWindow<T,ErrorT>	of(T value, Instant timestamp, BoundedWindow window, PaneInfo paneInfo, ErrorT failsafeValue)

Methods inherited from class java.lang.Object

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

Constructor Details

FailsafeValueInSingleWindow

public FailsafeValueInSingleWindow()

Method Details

getValue

public abstract T getValue()

Returns the value of this FailsafeValueInSingleWindow.

getTimestamp

public abstract Instant getTimestamp()

Returns the timestamp of this FailsafeValueInSingleWindow.

getWindow

public abstract BoundedWindow getWindow()

Returns the window of this FailsafeValueInSingleWindow.

getPaneInfo

public abstract PaneInfo getPaneInfo()

Returns the pane of this FailsafeValueInSingleWindow in its window.

getFailsafeValue

public abstract ErrorT getFailsafeValue()

Returns the failsafe value of this FailsafeValueInSingleWindow.

of

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