org.apache.beam.runners.fnexecution.jobsubmission

Interface PortablePipelineRunner

All Known Implementing Classes:

FlinkPipelineRunner, SparkPipelineRunner

public interface PortablePipelineRunner

Runs a portable Beam pipeline on some execution engine.

Method Summary

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

Method Detail

run

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

Throws:

java.lang.Exception