This closes #1073
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/49f94443 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/49f94443 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/49f94443 Branch: refs/heads/master Commit: 49f94443004a48c0c1524f3c431b73b0f94d53a2 Parents: d790dfe 44225cf Author: Sela <ans...@paypal.com> Authored: Fri Oct 14 16:54:54 2016 +0300 Committer: Sela <ans...@paypal.com> Committed: Fri Oct 14 16:54:54 2016 +0300 ---------------------------------------------------------------------- .../beam/runners/spark/EvaluationResult.java | 4 +- .../spark/translation/EvaluationContext.java | 3 +- .../streaming/StreamingEvaluationContext.java | 6 +- .../apache/beam/runners/spark/DeDupTest.java | 3 +- .../beam/runners/spark/EmptyInputTest.java | 1 - .../beam/runners/spark/SimpleWordCountTest.java | 6 +- .../apache/beam/runners/spark/TfIdfTest.java | 3 +- .../beam/runners/spark/io/AvroPipelineTest.java | 4 +- .../beam/runners/spark/io/NumShardsTest.java | 4 +- .../io/hadoop/HadoopFileFormatPipelineTest.java | 4 +- .../spark/translation/CombineGloballyTest.java | 1 - .../spark/translation/CombinePerKeyTest.java | 1 - .../spark/translation/DoFnOutputTest.java | 4 +- .../translation/MultiOutputWordCountTest.java | 2 - .../spark/translation/SerializationTest.java | 4 +- .../translation/WindowedWordCountTest.java | 10 +- .../streaming/EmptyStreamAssertionTest.java | 76 ++++++++ .../streaming/FlattenStreamingTest.java | 11 +- .../streaming/KafkaStreamingTest.java | 6 +- .../RecoverFromCheckpointStreamingTest.java | 179 ------------------ .../ResumeFromCheckpointStreamingTest.java | 182 +++++++++++++++++++ .../streaming/SimpleStreamingWordCountTest.java | 6 +- .../streaming/utils/PAssertStreaming.java | 87 ++++++--- 23 files changed, 346 insertions(+), 261 deletions(-) ----------------------------------------------------------------------