You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2016/10/14 14:11:06 UTC
[2/2] incubator-beam git commit: This closes #1073
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 <an...@paypal.com>
Authored: Fri Oct 14 16:54:54 2016 +0300
Committer: Sela <an...@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(-)
----------------------------------------------------------------------