Package org.apache.beam.sdk.transforms

Class DoFnOutputReceivers

java.lang.Object

org.apache.beam.sdk.transforms.DoFnOutputReceivers

@Internal
public class DoFnOutputReceivers
extends Object

Common DoFn.OutputReceiver and DoFn.MultiOutputReceiver classes.

Constructor Summary

Constructors

Constructor	Description
DoFnOutputReceivers()

Method Summary

Modifier and Type	Method	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 DoFnOutputReceivers.WindowedContextOutputReceiver.
static DoFn.MultiOutputReceiver	windowedMultiReceiver(DoFn<?,?>.WindowedContext context)	Returns a DoFn.MultiOutputReceiver that delegates to a DoFn.WindowedContext.
static DoFn.MultiOutputReceiver	windowedMultiReceiver(DoFn<?,?>.WindowedContext context, @Nullable 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 Details

DoFnOutputReceivers

public DoFnOutputReceivers()

Method Details

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 DoFn.MultiOutputReceiver windowedMultiReceiver(DoFn<?,?>.WindowedContext context,
 @Nullable Map<TupleTag<?>,Coder<?>> outputCoders)

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

windowedMultiReceiver

public static 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 DoFnOutputReceivers.WindowedContextOutputReceiver.