org.apache.beam.sdk.transforms

Interface DoFn.OutputReceiver<T>

Enclosing class:

DoFn<InputT,OutputT>

public static interface DoFn.OutputReceiver<T>

Receives values of the given type.

Method Summary

Modifier and Type	Method and Description
void	output(T output)
default void	outputWindowedValue(T output, Instant timestamp, java.util.Collection<? extends BoundedWindow> windows, PaneInfo paneInfo)
void	outputWithTimestamp(T output, Instant timestamp)

Method Detail

output

void output(T output)

outputWithTimestamp

void outputWithTimestamp(T output,
                         Instant timestamp)

outputWindowedValue

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