org.apache.beam.sdk.transforms

Class DoFnOutputReceivers

java.lang.Object

org.apache.beam.sdk.transforms.DoFnOutputReceivers

public class DoFnOutputReceivers
extends java.lang.Object

Common DoFn.OutputReceiver and DoFn.MultiOutputReceiver classes.

Constructor Summary

Constructors

Constructor and Description
DoFnOutputReceivers()

Method Summary

Modifier and Type	Method and Description
static <T> DoFn.OutputReceiver<Row>	rowReceiver(DoFn.WindowedContext context, TupleTag<T> outputTag, SchemaCoder<T> schemaCoder) Returns a DoFn.OutputReceiver that automatically converts a Row to the user's output type and delegates to WindowedContextOutputReceiver.
static <T> DoFn.MultiOutputReceiver	windowedMultiReceiver(DoFn.WindowedContext context) Returns a DoFn.MultiOutputReceiver that delegates to a DoFn.WindowedContext.
static <T> DoFn.MultiOutputReceiver	windowedMultiReceiver(DoFn.WindowedContext context, java.util.Map<TupleTag<?>,Coder<?>> outputCoders) Returns a DoFn.MultiOutputReceiver that delegates to a DoFn.WindowedContext.
static <T> DoFn.OutputReceiver<T>	windowedReceiver(DoFn.WindowedContext context, TupleTag<T> outputTag) Returns a DoFn.OutputReceiver that delegates to a DoFn.WindowedContext.

Methods inherited from class java.lang.Object

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

Constructor Detail

DoFnOutputReceivers

public DoFnOutputReceivers()

Method Detail

windowedReceiver

public static <T> DoFn.OutputReceiver<T> windowedReceiver(DoFn.WindowedContext context,
                                                          @Nullable
                                                          TupleTag<T> outputTag)

Returns a DoFn.OutputReceiver that delegates to a DoFn.WindowedContext.

windowedMultiReceiver

public static <T> DoFn.MultiOutputReceiver windowedMultiReceiver(DoFn.WindowedContext context,
                                                                 @Nullable
                                                                 java.util.Map<TupleTag<?>,Coder<?>> outputCoders)

Returns a DoFn.MultiOutputReceiver that delegates to a DoFn.WindowedContext.

windowedMultiReceiver

public static <T> DoFn.MultiOutputReceiver windowedMultiReceiver(DoFn.WindowedContext context)

Returns a DoFn.MultiOutputReceiver that delegates to a DoFn.WindowedContext.

This exists for backwards-compatibility with the Dataflow runner, and will be removed.

rowReceiver

public static <T> DoFn.OutputReceiver<Row> rowReceiver(DoFn.WindowedContext context,
                                                       @Nullable
                                                       TupleTag<T> outputTag,
                                                       SchemaCoder<T> schemaCoder)

Returns a DoFn.OutputReceiver that automatically converts a Row to the user's output type and delegates to WindowedContextOutputReceiver.