Package org.apache.beam.runners.fnexecution.control

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.