com.google.cloud.dataflow.sdk.runners

Class DataflowPipeline

java.lang.Object

com.google.cloud.dataflow.sdk.Pipeline

com.google.cloud.dataflow.sdk.runners.DataflowPipeline

public class DataflowPipeline
extends Pipeline

A DataflowPipeline, which returns a DataflowPipelineJob 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 DataflowPipeline	create(DataflowPipelineOptions options) Creates and returns a new DataflowPipeline instance for tests.
DataflowPipelineRunner	getRunner() Returns the configured pipeline runner.
DataflowPipelineJob	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

create

public static DataflowPipeline create(DataflowPipelineOptions options)

Creates and returns a new DataflowPipeline instance for tests.

run

public DataflowPipelineJob run()

Description copied from class: Pipeline

Runs the Pipeline.

Overrides:

run in class Pipeline

getRunner

public DataflowPipelineRunner getRunner()

Description copied from class: Pipeline

Returns the configured pipeline runner.

Overrides:

getRunner in class Pipeline