org.apache.beam.sdk.values

Interface WindowedValue<T>

Type Parameters:

T - the type of the primary data for the value.

public interface WindowedValue<T>

A value along with Beam's windowing information and all other metadata.

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<WindowedValue<T>>	explodeWindows() A representation of each of the actual values represented by this compressed WindowedValue, one per window.
PaneInfo	getPaneInfo() The PaneInfo associated with this WindowedValue.
Instant	getTimestamp() The timestamp of this value in event time.
T	getValue() The primary data for this value.
java.util.Collection<? extends BoundedWindow>	getWindows() Returns the windows of this WindowedValue.
<OtherT> WindowedValue<OtherT>	withValue(OtherT value) A WindowedValue with identical metadata to the current one, but with the provided value.

Method Detail

getValue

T getValue()

The primary data for this value.

getTimestamp

Instant getTimestamp()

The timestamp of this value in event time.

getWindows

java.util.Collection<? extends BoundedWindow> getWindows()

Returns the windows of this WindowedValue.

getPaneInfo

PaneInfo getPaneInfo()

The PaneInfo associated with this WindowedValue.

explodeWindows

java.lang.Iterable<WindowedValue<T>> explodeWindows()

A representation of each of the actual values represented by this compressed WindowedValue, one per window.

withValue

<OtherT> WindowedValue<OtherT> withValue(OtherT value)

A WindowedValue with identical metadata to the current one, but with the provided value.