beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amits...@apache.org
Subject [2/2] incubator-beam git commit: This closes #1073
Date Fri, 14 Oct 2016 14:11:06 GMT
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 <ansela@paypal.com>
Authored: Fri Oct 14 16:54:54 2016 +0300
Committer: Sela <ansela@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(-)
----------------------------------------------------------------------



Mime
View raw message