Package org.apache.beam.runners.portability

Class PortableRunner

java.lang.Object

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

org.apache.beam.runners.portability.PortableRunner

public class PortableRunner
extends PipelineRunner<PipelineResult>

A PipelineRunner a Pipeline against a JobService.

Method Summary

Modifier and Type	Method	Description
static PortableRunner	fromOptions(PipelineOptions options)	Constructs a runner from the provided options.
PipelineResult	run(Pipeline pipeline)	Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.
String	toString()

Methods inherited from class org.apache.beam.sdk.PipelineRunner

create, run, run

Methods inherited from class java.lang.Object

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

Method Details

fromOptions

public static PortableRunner fromOptions(PipelineOptions options)

Constructs a runner from the provided options.

Parameters:

options - Properties which configure the runner.

Returns:

The newly created runner.

run

public PipelineResult run(Pipeline pipeline)

Description copied from class: PipelineRunner

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

Specified by:

run in class PipelineRunner<PipelineResult>

toString

public String toString()

Overrides:

toString in class Object