org.apache.beam.runners.fnexecution.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 and Description
PortablePipelineResult	run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline, JobInfo jobInfo)

Method Detail

run

PortablePipelineResult run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline pipeline,
                           JobInfo jobInfo)
                    throws java.lang.Exception

Throws:

java.lang.Exception