Interface OutputReceiverFactory


public interface OutputReceiverFactory
A factory that can create output receivers during an executable stage.
  • Method Summary

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

    • create

      <OutputT> FnDataReceiver<OutputT> create(String pCollectionId)
      Get a new FnDataReceiver for an output PCollection.

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