Package org.apache.beam.runners.portability.testing

Class TestUniversalRunner

java.lang.Object

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

org.apache.beam.runners.portability.testing.TestUniversalRunner

public class TestUniversalRunner
extends PipelineRunner<PipelineResult>

A PipelineRunner a Pipeline against a JobService.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	TestUniversalRunner.Options
static class	TestUniversalRunner.OptionsRegistrar	Register TestUniversalRunner.Options.
static class	TestUniversalRunner.RunnerRegistrar	Registrar for the portable runner.

Method Summary

Modifier and Type	Method	Description
static TestUniversalRunner	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.

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, toString, wait, wait, wait

Method Details

fromOptions

public static TestUniversalRunner 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>