org.apache.beam.sdk

Class PipelineRunner<ResultT extends PipelineResult>

java.lang.Object

org.apache.beam.sdk.PipelineRunner<ResultT>

Type Parameters:

ResultT - the type of the result of run(org.apache.beam.sdk.Pipeline), often a handle to a running job.

Direct Known Subclasses:

ApexRunner, CrashingRunner, DataflowRunner, DirectRunner, FlinkRunner, SparkRunner, SparkRunnerDebugger, TestApexRunner, TestDataflowRunner, TestFlinkRunner, TestSparkRunner

public abstract class PipelineRunner<ResultT extends PipelineResult>
extends java.lang.Object

A PipelineRunner runs a Pipeline.

Constructor Summary

Constructors

Constructor and Description
PipelineRunner()

Method Summary

Modifier and Type	Method and Description
static PipelineRunner<? extends PipelineResult>	fromOptions(PipelineOptions options) Constructs a runner from the provided PipelineOptions.
abstract ResultT	run(Pipeline pipeline) Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PipelineRunner

public PipelineRunner()

Method Detail

fromOptions

public static PipelineRunner<? extends PipelineResult> fromOptions(PipelineOptions options)

Constructs a runner from the provided PipelineOptions.

Returns:

The newly created runner.

run

public abstract ResultT run(Pipeline pipeline)

Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.