Package org.apache.beam.sdk.values

Class WindowedValues.Builder<T>

java.lang.Object

org.apache.beam.sdk.values.WindowedValues.Builder<T>

All Implemented Interfaces:

OutputBuilder<T>, WindowedValue<T>

Enclosing class:

WindowedValues

public static class WindowedValues.Builder<T>
extends Object
implements OutputBuilder<T>

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
WindowedValue<T>	build()
CausedByDrain	causedByDrain()
Collection<WindowedValues.Builder<T>>	explodeWindows()	A representation of each of the actual values represented by this compressed WindowedValue, one per window.
@Nullable Context	getOpenTelemetryContext()
PaneInfo	getPaneInfo()	The PaneInfo associated with this WindowedValue.
@Nullable String	getRecordId()
@Nullable Long	getRecordOffset()
Instant	getTimestamp()	The timestamp of this value in event time.
T	getValue()	The primary data for this value.
ValueKind	getValueKind()	Returns the ValueKind associated with this WindowedValue.
Collection<? extends BoundedWindow>	getWindows()	Returns the windows of this WindowedValue.
void	output()
WindowedValues.Builder<T>	setCausedByDrain(CausedByDrain causedByDrain)
WindowedValues.Builder<T>	setOpenTelemetryContext(@Nullable Context openTelemetryContext)
WindowedValues.Builder<T>	setPaneInfo(PaneInfo paneInfo)
WindowedValues.Builder<T>	setReceiver(org.apache.beam.sdk.util.WindowedValueReceiver<T> receiver)
WindowedValues.Builder<T>	setRecordId(@Nullable String recordId)
WindowedValues.Builder<T>	setRecordOffset(@Nullable Long recordOffset)
WindowedValues.Builder<T>	setTimestamp(Instant timestamp)
WindowedValues.Builder<T>	setValue(T value)
WindowedValues.Builder<T>	setValueKind(ValueKind valueKind)
WindowedValues.Builder<T>	setWindow(BoundedWindow window)
WindowedValues.Builder<T>	setWindows(Collection<? extends BoundedWindow> windows)
String	toString()
<OtherT> WindowedValues.Builder<OtherT>	withValue(OtherT newValue)	A WindowedValue with identical metadata to the current one, but with the provided value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

Builder

public Builder()

Method Details

setValue

public WindowedValues.Builder<T> setValue(T value)

Specified by:

setValue in interface OutputBuilder<T>

setTimestamp

public WindowedValues.Builder<T> setTimestamp(Instant timestamp)

Specified by:

setTimestamp in interface OutputBuilder<T>

setWindows

public WindowedValues.Builder<T> setWindows(Collection<? extends BoundedWindow> windows)

Specified by:

setWindows in interface OutputBuilder<T>

setPaneInfo

public WindowedValues.Builder<T> setPaneInfo(PaneInfo paneInfo)

Specified by:

setPaneInfo in interface OutputBuilder<T>

setWindow

public WindowedValues.Builder<T> setWindow(BoundedWindow window)

Specified by:

setWindow in interface OutputBuilder<T>

setRecordId

public WindowedValues.Builder<T> setRecordId(@Nullable String recordId)

Specified by:

setRecordId in interface OutputBuilder<T>

setRecordOffset

public WindowedValues.Builder<T> setRecordOffset(@Nullable Long recordOffset)

Specified by:

setRecordOffset in interface OutputBuilder<T>

setCausedByDrain

public WindowedValues.Builder<T> setCausedByDrain(CausedByDrain causedByDrain)

Specified by:

setCausedByDrain in interface OutputBuilder<T>

setOpenTelemetryContext

public WindowedValues.Builder<T> setOpenTelemetryContext(@Nullable Context openTelemetryContext)

Specified by:

setOpenTelemetryContext in interface OutputBuilder<T>

setValueKind

public WindowedValues.Builder<T> setValueKind(ValueKind valueKind)

Specified by:

setValueKind in interface OutputBuilder<T>

setReceiver

public WindowedValues.Builder<T> setReceiver(org.apache.beam.sdk.util.WindowedValueReceiver<T> receiver)

getValue

public T getValue()

Description copied from interface: WindowedValue

The primary data for this value.

Specified by:

getValue in interface WindowedValue<T>

getTimestamp

public Instant getTimestamp()

Description copied from interface: WindowedValue

The timestamp of this value in event time.

Specified by:

getTimestamp in interface WindowedValue<T>

getOpenTelemetryContext

public @Nullable Context getOpenTelemetryContext()

Specified by:

getOpenTelemetryContext in interface WindowedValue<T>

getWindows

public Collection<? extends BoundedWindow> getWindows()

Description copied from interface: WindowedValue

Returns the windows of this WindowedValue.

Specified by:

getWindows in interface WindowedValue<T>

getPaneInfo

public PaneInfo getPaneInfo()

Description copied from interface: WindowedValue

The PaneInfo associated with this WindowedValue.

Specified by:

getPaneInfo in interface WindowedValue<T>

getRecordId

public @Nullable String getRecordId()

Specified by:

getRecordId in interface WindowedValue<T>

getRecordOffset

public @Nullable Long getRecordOffset()

Specified by:

getRecordOffset in interface WindowedValue<T>

causedByDrain

public CausedByDrain causedByDrain()

Specified by:

causedByDrain in interface WindowedValue<T>

getValueKind

public ValueKind getValueKind()

Description copied from interface: WindowedValue

Returns the ValueKind associated with this WindowedValue.

Specified by:

getValueKind in interface WindowedValue<T>

explodeWindows

public Collection<WindowedValues.Builder<T>> explodeWindows()

Description copied from interface: WindowedValue

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

Specified by:

explodeWindows in interface WindowedValue<T>

withValue

@Pure
public <OtherT> WindowedValues.Builder<OtherT> withValue(OtherT newValue)

Description copied from interface: WindowedValue

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

Specified by:

withValue in interface WindowedValue<T>

output

public void output()

Specified by:

output in interface OutputBuilder<T>

build

public WindowedValue<T> build()

toString

public String toString()

Overrides:

toString in class Object