Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.testing
Class TestDataflowPipelineRunner
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.runners.PipelineRunner<DataflowPipelineJob>
-
- com.google.cloud.dataflow.sdk.testing.TestDataflowPipelineRunner
-
public class TestDataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
TestDataflowPipelineRunner
is a pipeline runner that wraps aDataflowPipelineRunner
when running tests against theTestPipeline
.- See Also:
TestPipeline
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method and Description <OutputT extends POutput,InputT extends PInput>
OutputTapply(PTransform<InputT,OutputT> transform, InputT input)
Applies a transform to the given input, returning the output.static TestDataflowPipelineRunner
fromOptions(PipelineOptions options)
Constructs a runner from the provided options.DataflowPipelineJob
run(Pipeline pipeline)
Processes the given Pipeline, returning the results.String
toString()
-
-
-
Method Detail
-
fromOptions
public static TestDataflowPipelineRunner 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, returning the results.- Specified by:
run
in classPipelineRunner<DataflowPipelineJob>
-
apply
public <OutputT extends POutput,InputT extends PInput> OutputT apply(PTransform<InputT,OutputT> transform, InputT input)
Description copied from class:PipelineRunner
Applies a transform to the given input, returning the output.The default implementation calls PTransform.apply(input), but can be overridden to customize behavior for a particular runner.
- Overrides:
apply
in classPipelineRunner<DataflowPipelineJob>
-
-