You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/09 20:17:41 UTC

[4/4] beam git commit: This closes #2944: Cherry pick #2940 onto release-2.0.0

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 <kl...@google.com>
Authored: Tue May 9 13:17:12 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
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
----------------------------------------------------------------------