org.apache.beam.runners.dataflow

Class TestDataflowRunner

java.lang.Object

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

org.apache.beam.runners.dataflow.TestDataflowRunner

public class TestDataflowRunner
extends PipelineRunner<DataflowPipelineJob>

TestDataflowRunner is a pipeline runner that wraps a DataflowRunner when running tests against the TestPipeline.

See Also:

TestPipeline

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

fromOptions

public static TestDataflowRunner fromOptions(PipelineOptions options)

Constructs a runner from the provided options.

run

public DataflowPipelineJob 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<DataflowPipelineJob>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object