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.
@Nullable String	getCurrentRecordId()
@Nullable Long	getCurrentRecordOffset()
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.

getCurrentRecordId

@Nullable String getCurrentRecordId()

getCurrentRecordOffset

@Nullable Long getCurrentRecordOffset()

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.