Class Twister2RunnerRegistrar.Runner

java.lang.Object
org.apache.beam.runners.twister2.Twister2RunnerRegistrar.Runner
All Implemented Interfaces:
org.apache.beam.sdk.runners.PipelineRunnerRegistrar
Enclosing class:
Twister2RunnerRegistrar

@AutoService(org.apache.beam.sdk.runners.PipelineRunnerRegistrar.class) public static class Twister2RunnerRegistrar.Runner extends Object implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar
Pipeline runner registrar.
  • Constructor Details

    • Runner

      public Runner()
  • Method Details

    • getPipelineRunners

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