org.apache.beam.sdk.transforms

Class DoFnOutputReceivers

java.lang.Object

org.apache.beam.sdk.transforms.DoFnOutputReceivers

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.MultiOutputReceiver	windowedMultiReceiver(DoFn.WindowedContext context) Returns a DoFn.MultiOutputReceiver that delegates to a DoFn.WindowedContext.
static <T> DoFn.OutputReceiver<T>	windowedReceiver(DoFn.WindowedContext context, 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)

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