org.apache.beam.sdk.transforms

Class DoFnOutputReceivers

java.lang.Object

org.apache.beam.sdk.transforms.DoFnOutputReceivers

@Internal
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, @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.
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, @Nullable 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, @Nullable 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.