public class TestDataflowRunner extends PipelineRunner<DataflowPipelineJob>
TestDataflowRunner
is a pipeline runner that wraps a DataflowRunner
when running
tests against the TestPipeline
.TestPipeline
Modifier and Type | Method and Description |
---|---|
static TestDataflowRunner |
fromOptions(PipelineOptions options)
Constructs a runner from the provided options.
|
DataflowPipelineJob |
run(Pipeline pipeline)
Processes the given
Pipeline , potentially asynchronously, returning a runner-specific
type of result. |
java.lang.String |
toString() |
create, run, run
public static TestDataflowRunner fromOptions(PipelineOptions options)
public DataflowPipelineJob run(Pipeline pipeline)
PipelineRunner
Pipeline
, potentially asynchronously, returning a runner-specific
type of result.run
in class PipelineRunner<DataflowPipelineJob>
public java.lang.String toString()
toString
in class java.lang.Object