Interface PTransformRunnerFactory<T>

  • All Known Implementing Classes:
    CombineRunners.PrecombineFactory

    public interface PTransformRunnerFactory<T>
    A factory able to instantiate an appropriate handler for a given PTransform.
    • Method Detail

      • createRunnerForPTransform

        T createRunnerForPTransform​(PTransformRunnerFactory.Context context)
                             throws java.io.IOException
        Creates and returns a handler for a given PTransform. Note that the handler must support processing multiple bundles. The handler will be discarded if bundle processing fails or management of the handler between bundle processing fails. The handler may also be discarded due to memory pressure.
        Throws:
        java.io.IOException