Package org.apache.beam.runners.jobsubmission

Interface PortablePipelineRunner

All Known Implementing Classes:
FlinkPipelineRunner, PortablePipelineJarCreator, SparkPipelineRunner
public interface PortablePipelineRunner
Runs a portable Beam pipeline on some execution engine.

  • Method Summary

    Modifier and Type
    Method
    Description
    PortablePipelineResult
    run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, JobInfo jobInfo)