org.apache.beam.runners.fnexecution.control

Interface OutputReceiverFactory

All Known Implementing Classes:

TimerReceiverFactory

public interface OutputReceiverFactory

A factory that can create output receivers during an executable stage.

Method Summary

Modifier and Type	Method and Description
<OutputT> FnDataReceiver<OutputT>	create(java.lang.String pCollectionId) Get a new RemoteOutputReceiver for an output PCollection.

Method Detail

create

<OutputT> FnDataReceiver<OutputT> create(java.lang.String pCollectionId)

Get a new RemoteOutputReceiver for an output PCollection.

This call should only be invoked once per PCollection id per factory.