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 and 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 and 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 Detail

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>