Package org.apache.beam.sdk.transforms

Interface DoFn.MultiOutputReceiver

Enclosing class:

DoFn<InputT extends @Nullable Object,OutputT extends @Nullable Object>

public static interface DoFn.MultiOutputReceiver

Receives tagged output for a multi-output function.

Method Summary

Modifier and Type	Method	Description
<T> DoFn.OutputReceiver<T>	get(TupleTag<T> tag)	Returns an DoFn.OutputReceiver for the given tag.
<T> DoFn.OutputReceiver<Row>	getRowReceiver(TupleTag<T> tag)	Returns a DoFn.OutputReceiver for publishing Row objects to the given tag.

Method Details

get

<T> DoFn.OutputReceiver<T> get(TupleTag<T> tag)

Returns an DoFn.OutputReceiver for the given tag. *

getRowReceiver

<T> DoFn.OutputReceiver<Row> getRowReceiver(TupleTag<T> tag)

Returns a DoFn.OutputReceiver for publishing Row objects to the given tag.

The PCollection representing this tag must have a schema registered in order to call this function.