Closes #154
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6ab55554 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6ab55554 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6ab55554 Branch: refs/heads/master Commit: 6ab55554cb9bf19cc6b62ac379dab4322150e637 Parents: 2ca5474 208c0db Author: Dan Halperin <dhalp...@google.com> Authored: Fri Apr 8 18:29:29 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Fri Apr 8 18:29:29 2016 -0700 ---------------------------------------------------------------------- .../sdk/testing/TestDataflowPipelineRunner.java | 83 +++++++++++++------ .../dataflow/sdk/testing/TestPipeline.java | 48 +++++------ .../sdk/runners/PipelineRunnerTest.java | 2 - .../cloud/dataflow/sdk/testing/PAssertTest.java | 50 ++++------- .../testing/TestDataflowPipelineRunnerTest.java | 87 ++++++++++++++++---- 5 files changed, 168 insertions(+), 102 deletions(-) ----------------------------------------------------------------------
