Class PrismRegistrar.Runner

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

@AutoService(org.apache.beam.sdk.runners.PipelineRunnerRegistrar.class) public static class PrismRegistrar.Runner extends Object implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar
Registers PrismRunner and TestPrismRunner with PipelineRunnerRegistrar.
  • 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