Interface OutputReceiverFactory
public interface OutputReceiverFactory
A factory that can create output receivers during an executable stage.
-
Method Summary
Modifier and TypeMethodDescription<OutputT> FnDataReceiver
<OutputT> Get a newFnDataReceiver
for an output PCollection.
-
Method Details
-
create
Get a newFnDataReceiver
for an output PCollection.This call should only be invoked once per PCollection id per factory.
-