com.google.cloud.dataflow.sdk.runners

Class DirectPipeline

java.lang.Object

com.google.cloud.dataflow.sdk.Pipeline

com.google.cloud.dataflow.sdk.runners.DirectPipeline

public class DirectPipeline
extends Pipeline

A DirectPipeline, which returns a DirectPipelineRunner.EvaluationResults subclass of PipelineResult from Pipeline.run().

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.Pipeline

Pipeline.PipelineVisitor

Method Summary

Methods

Modifier and Type	Method and Description
static DirectPipeline	createForTest() Creates and returns a new DirectPipeline instance for tests.
DirectPipelineRunner	getRunner() Returns the configured pipeline runner.
DirectPipelineRunner.EvaluationResults	run() Runs the Pipeline.

Methods inherited from class com.google.cloud.dataflow.sdk.Pipeline

addValueInternal, apply, applyTransform, begin, create, getCoderRegistry, getFullName, getInput, getOptions, getOutput, setCoderRegistry, toString, traverseTopologically

Methods inherited from class java.lang.Object

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

Method Detail

createForTest

public static DirectPipeline createForTest()

Creates and returns a new DirectPipeline instance for tests.

run

public DirectPipelineRunner.EvaluationResults run()

Description copied from class: Pipeline

Runs the Pipeline.

Overrides:

run in class Pipeline

getRunner

public DirectPipelineRunner getRunner()

Description copied from class: Pipeline

Returns the configured pipeline runner.

Overrides:

getRunner in class Pipeline