This closes #2944: Cherry pick #2940 onto release-2.0.0 Move TestDataflowRunner into dataflow package Register the TestDataflowRunner via registrar
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9f7521f8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9f7521f8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9f7521f8 Branch: refs/heads/release-2.0.0 Commit: 9f7521f8d06ba198866fbe32ca3c2008977de1fa Parents: 61c5a42 d305d6d Author: Kenneth Knowles <[email protected]> Authored: Tue May 9 13:17:12 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue May 9 13:17:12 2017 -0700 ---------------------------------------------------------------------- ...job_beam_PostCommit_Java_MavenInstall.groovy | 2 +- ...tCommit_Java_ValidatesRunner_Dataflow.groovy | 2 +- .../job_beam_Release_NightlySnapshot.groovy | 2 +- examples/java/pom.xml | 4 +- .../dataflow/DataflowPipelineRegistrar.java | 2 +- .../dataflow/TestDataflowPipelineOptions.java | 28 + .../runners/dataflow/TestDataflowRunner.java | 322 +++++++++ .../testing/TestDataflowPipelineOptions.java | 28 - .../dataflow/testing/TestDataflowRunner.java | 325 --------- .../runners/dataflow/testing/package-info.java | 24 - .../runners/dataflow/DataflowMetricsTest.java | 1 - .../dataflow/DataflowPipelineJobTest.java | 1 - .../dataflow/DataflowPipelineRegistrarTest.java | 2 +- .../dataflow/TestDataflowRunnerTest.java | 652 ++++++++++++++++++ .../testing/TestDataflowRunnerTest.java | 655 ------------------- .../apache/beam/sdk/testing/TestPipeline.java | 2 +- 16 files changed, 1010 insertions(+), 1042 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/9f7521f8/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowPipelineJobTest.java ----------------------------------------------------------------------
