Package org.apache.beam.sdk.transforms
Class DoFnOutputReceivers
- java.lang.Object
-
- org.apache.beam.sdk.transforms.DoFnOutputReceivers
-
@Internal public class DoFnOutputReceivers extends java.lang.Object
CommonDoFn.OutputReceiver
andDoFn.MultiOutputReceiver
classes.
-
-
Constructor Summary
Constructors Constructor Description DoFnOutputReceivers()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> DoFn.OutputReceiver<Row>
rowReceiver(DoFn.WindowedContext context, @Nullable TupleTag<T> outputTag, SchemaCoder<T> schemaCoder)
Returns aDoFn.OutputReceiver
that automatically converts aRow
to the user's output type and delegates toDoFnOutputReceivers.WindowedContextOutputReceiver
.static <T> DoFn.MultiOutputReceiver
windowedMultiReceiver(DoFn.WindowedContext context)
Returns aDoFn.MultiOutputReceiver
that delegates to aDoFn.WindowedContext
.static <T> DoFn.MultiOutputReceiver
windowedMultiReceiver(DoFn.WindowedContext context, @Nullable java.util.Map<TupleTag<?>,Coder<?>> outputCoders)
Returns aDoFn.MultiOutputReceiver
that delegates to aDoFn.WindowedContext
.static <T> DoFn.OutputReceiver<T>
windowedReceiver(DoFn.WindowedContext context, @Nullable TupleTag<T> outputTag)
Returns aDoFn.OutputReceiver
that delegates to aDoFn.WindowedContext
.
-
-
-
Method Detail
-
windowedReceiver
public static <T> DoFn.OutputReceiver<T> windowedReceiver(DoFn.WindowedContext context, @Nullable TupleTag<T> outputTag)
Returns aDoFn.OutputReceiver
that delegates to aDoFn.WindowedContext
.
-
windowedMultiReceiver
public static <T> DoFn.MultiOutputReceiver windowedMultiReceiver(DoFn.WindowedContext context, @Nullable java.util.Map<TupleTag<?>,Coder<?>> outputCoders)
Returns aDoFn.MultiOutputReceiver
that delegates to aDoFn.WindowedContext
.
-
windowedMultiReceiver
public static <T> DoFn.MultiOutputReceiver windowedMultiReceiver(DoFn.WindowedContext context)
Returns aDoFn.MultiOutputReceiver
that delegates to aDoFn.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 aDoFn.OutputReceiver
that automatically converts aRow
to the user's output type and delegates toDoFnOutputReceivers.WindowedContextOutputReceiver
.
-
-