Package org.apache.beam.sdk.values

Interface OutputBuilder<T>

All Superinterfaces:

WindowedValue<T>

All Known Implementing Classes:

WindowedValues.Builder

public interface OutputBuilder<T>
extends WindowedValue<T>

A builder for an output, to set all the fields and extended metadata of a Beam value.

Which fields are required or allowed to be set depends on the context of the builder.

It is allowed to modify an instance and then call output() again.

Not intended to be implemented by Beam users. This interface will be expanded in ways that are backwards-incompatible, by requiring implementors to add methods.

Method Summary

Modifier and Type	Method	Description
void	output()
OutputBuilder<T>	setPaneInfo(PaneInfo paneInfo)
OutputBuilder<T>	setRecordId(@Nullable String recordId)
OutputBuilder<T>	setRecordOffset(@Nullable Long recordOffset)
OutputBuilder<T>	setTimestamp(Instant timestamp)
OutputBuilder<T>	setValue(T value)
OutputBuilder<T>	setWindow(BoundedWindow window)
OutputBuilder<T>	setWindows(Collection<? extends BoundedWindow> windows)

Methods inherited from interface org.apache.beam.sdk.values.WindowedValue

explodeWindows, getPaneInfo, getRecordId, getRecordOffset, getTimestamp, getValue, getWindows, withValue

Method Details

setValue

OutputBuilder<T> setValue(T value)

setTimestamp

OutputBuilder<T> setTimestamp(Instant timestamp)

setWindow

OutputBuilder<T> setWindow(BoundedWindow window)

setWindows

OutputBuilder<T> setWindows(Collection<? extends BoundedWindow> windows)

setPaneInfo

OutputBuilder<T> setPaneInfo(PaneInfo paneInfo)

setRecordId

OutputBuilder<T> setRecordId(@Nullable String recordId)

setRecordOffset

OutputBuilder<T> setRecordOffset(@Nullable Long recordOffset)

output

void output()