Package org.apache.beam.runners.direct

Class DirectRunner

java.lang.Object

org.apache.beam.sdk.PipelineRunner<DirectRunner.DirectPipelineResult>

org.apache.beam.runners.direct.DirectRunner

public class DirectRunner
extends PipelineRunner<DirectRunner.DirectPipelineResult>

A PipelineRunner that executes a Pipeline within the process that constructed the Pipeline.

The DirectRunner is suitable for running a Pipeline on small scale, example, and test data, and should be used for ensuring that processing logic is correct. It also is appropriate for executing unit tests and performs additional work to ensure that behavior contained within a Pipeline does not break assumptions within the Beam model, to improve the ability to execute a Pipeline at scale on a distributed backend.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DirectRunner.DirectPipelineResult	The result of running a Pipeline with the DirectRunner.

Method Summary

Modifier and Type	Method	Description
static DirectRunner	fromOptions(PipelineOptions options)	Construct a DirectRunner from the provided options.
DirectRunner.DirectPipelineResult	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 DirectRunner fromOptions(PipelineOptions options)

Construct a DirectRunner from the provided options.

run

public DirectRunner.DirectPipelineResult 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<DirectRunner.DirectPipelineResult>