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 java.lang.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	getPane()	Returns the pane of this FailsafeValueInSingleWindow in its window.
abstract org.joda.time.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, org.joda.time.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 Detail

FailsafeValueInSingleWindow

public FailsafeValueInSingleWindow()

Method Detail

getValue

public abstract T getValue()

Returns the value of this FailsafeValueInSingleWindow.

getTimestamp

public abstract org.joda.time.Instant getTimestamp()

Returns the timestamp of this FailsafeValueInSingleWindow.

getWindow

public abstract BoundedWindow getWindow()

Returns the window of this FailsafeValueInSingleWindow.

getPane

public abstract PaneInfo getPane()

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,
                                                                              org.joda.time.Instant timestamp,
                                                                              BoundedWindow window,
                                                                              PaneInfo paneInfo,
                                                                              ErrorT failsafeValue)