Package org.apache.beam.sdk.transforms

Interface DoFn.OutputReceiver<T>

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
void	output(T output)
default void	outputWindowedValue(T output, Instant timestamp, Collection<? extends BoundedWindow> windows, PaneInfo paneInfo)
void	outputWithTimestamp(T output, Instant timestamp)

Method Details

output

void output(T output)

outputWithTimestamp

void outputWithTimestamp(T output,
 Instant timestamp)

outputWindowedValue

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