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

Class TestPortableRunner

java.lang.Object

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

org.apache.beam.runners.portability.testing.TestPortableRunner

public class TestPortableRunner
extends PipelineRunner<PipelineResult>

TestPortableRunner is a pipeline runner that wraps a PortableRunner when running tests against the TestPipeline.

This runner requires a JobServerDriver subclass with the following factory method: public static JobServerDriver fromParams(String[] args)

See Also:

• TestPipeline

Method Summary

Modifier and Type	Method	Description
static TestPortableRunner	fromOptions(PipelineOptions 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 TestPortableRunner fromOptions(PipelineOptions options)

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>