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 and Description
static class	FailsafeValueInSingleWindow.Coder<T,ErrorT> A coder for FailsafeValueInSingleWindow.

Constructor Summary

Constructors

Constructor and Description
FailsafeValueInSingleWindow()

Method Summary

Modifier and Type	Method and Description
abstract ErrorT	getFailsafeValue() Returns the failsafe value of this FailsafeValueInSingleWindow.
abstract PaneInfo	getPane() 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 Detail

FailsafeValueInSingleWindow

public FailsafeValueInSingleWindow()

Method Detail

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.

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