Class PortableRunnerRegistrar

java.lang.Object
org.apache.beam.runners.portability.PortableRunnerRegistrar
All Implemented Interfaces:
org.apache.beam.sdk.runners.PipelineRunnerRegistrar

@AutoService(org.apache.beam.sdk.runners.PipelineRunnerRegistrar.class) public class PortableRunnerRegistrar extends Object implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar
Registrar for the portable runner.
  • Constructor Details

    • PortableRunnerRegistrar

      public PortableRunnerRegistrar()
  • Method Details

    • getPipelineRunners

      public Iterable<Class<? extends PipelineRunner<?>>> getPipelineRunners()
      Specified by:
      getPipelineRunners in interface org.apache.beam.sdk.runners.PipelineRunnerRegistrar