Class TestUniversalRunner.RunnerRegistrar

java.lang.Object
org.apache.beam.runners.portability.testing.TestUniversalRunner.RunnerRegistrar
All Implemented Interfaces:
org.apache.beam.sdk.runners.PipelineRunnerRegistrar
Enclosing class:
TestUniversalRunner

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

    • RunnerRegistrar

      public RunnerRegistrar()
  • Method Details

    • getPipelineRunners

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