org.apache.beam.sdk.transforms

Interface DoFn.MultiOutputReceiver

Enclosing class:

DoFn<InputT,OutputT>

public static interface DoFn.MultiOutputReceiver

Receives tagged output for a multi-output function.

Method Summary

Modifier and Type	Method and 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 Detail

get

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

Returns an DoFn.OutputReceiver for the given tag. *

getRowReceiver

@Experimental(value=SCHEMAS)
<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.