Package 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	Description
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.
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 Details

getValue

@Pure
T getValue()

The primary data for this value.

getTimestamp

@Pure
Instant getTimestamp()

The timestamp of this value in event time.

getWindows

@Pure
Collection<? extends BoundedWindow> getWindows()

Returns the windows of this WindowedValue.

getPaneInfo

@Pure
PaneInfo getPaneInfo()

The PaneInfo associated with this WindowedValue.

explodeWindows

@Pure
Iterable<WindowedValue<T>> explodeWindows()

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

withValue

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

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