Package org.apache.beam.sdk.transforms

Interface DoFn.OutputReceiver<T>

All Known Implementing Classes:

TestOutputReceiver

Enclosing class:

DoFn<InputT extends @Nullable Object,OutputT extends @Nullable Object>

public static interface DoFn.OutputReceiver<T>

Receives values of the given type.

Method Summary

Modifier and Type	Method	Description
OutputBuilder<T>	builder(T value)
default void	output(T value)
default void	outputWindowedValue(T value, Instant timestamp, Collection<? extends BoundedWindow> windows, PaneInfo paneInfo)
default void	outputWindowedValue(T value, Instant timestamp, Collection<? extends BoundedWindow> windows, PaneInfo paneInfo, ValueKind valueKind)
default void	outputWithTimestamp(T value, Instant timestamp)

Method Details

builder

OutputBuilder<T> builder(T value)

output

default void output(T value)

outputWithTimestamp

default void outputWithTimestamp(T value,
 Instant timestamp)

outputWindowedValue

default void outputWindowedValue(T value,
 Instant timestamp,
 Collection<? extends BoundedWindow> windows,
 PaneInfo paneInfo)

outputWindowedValue

default void outputWindowedValue(T value,
 Instant timestamp,
 Collection<? extends BoundedWindow> windows,
 PaneInfo paneInfo,
 ValueKind valueKind)