Closes #2417
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7a2fe68f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7a2fe68f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7a2fe68f Branch: refs/heads/master Commit: 7a2fe68fd37bf60b357d9894ba0c365892154bcb Parents: 37e5321 e8f0922 Author: bchambers <[email protected]> Authored: Mon Apr 24 11:17:08 2017 -0700 Committer: bchambers <[email protected]> Committed: Mon Apr 24 11:56:59 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/spark/TestSparkRunner.java | 35 ++-- .../ResumeFromCheckpointStreamingTest.java | 72 ++++---- .../org/apache/beam/sdk/testing/PAssert.java | 164 ++++++++++++------- .../beam/sdk/testing/SuccessOrFailure.java | 82 ++++++++++ .../apache/beam/sdk/testing/PAssertTest.java | 55 +++++++ 5 files changed, 307 insertions(+), 101 deletions(-) ----------------------------------------------------------------------
