Class FlinkRunnerRegistrar.Runner

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

@AutoService(org.apache.beam.sdk.runners.PipelineRunnerRegistrar.class) public static class FlinkRunnerRegistrar.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