Google Cloud Dataflow SDK for Java, version 1.9.1
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
ADirectPipeline
is aPipeline
that returnsDirectPipelineRunner.EvaluationResults
when it isPipeline.run()
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.Pipeline
Pipeline.PipelineExecutionException, Pipeline.PipelineVisitor
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method and Description static DirectPipeline
createForTest()
Creates and returns a new DirectPipeline instance for tests.DirectPipelineRunner
getRunner()
Returns the configuredPipelineRunner
.DirectPipelineRunner.EvaluationResults
run()
Runs thePipeline
using itsPipelineRunner
.String
toString()
-
Methods inherited from class com.google.cloud.dataflow.sdk.Pipeline
addValueInternal, apply, apply, applyTransform, applyTransform, begin, create, getCoderRegistry, getFullNameForTesting, getOptions, setCoderRegistry, traverseTopologically
-
-
-
-
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 thePipeline
using itsPipelineRunner
.
-
getRunner
public DirectPipelineRunner getRunner()
Description copied from class:Pipeline
Returns the configuredPipelineRunner
.
-
-