beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [13/13] incubator-beam git commit: This closes #797
Date Mon, 08 Aug 2016 20:40:48 GMT
This closes #797


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/574c3777
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/574c3777
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/574c3777

Branch: refs/heads/master
Commit: 574c3777ddb6d9e8f5afb39e7ec14913ea52a8e8
Parents: bb00810 f5df358
Author: Kenneth Knowles <klk@google.com>
Authored: Mon Aug 8 13:40:21 2016 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Mon Aug 8 13:40:21 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/flink/examples/TFIDF.java      |  28 +--
 .../beam/runners/flink/examples/WordCount.java  |   5 +-
 .../flink/examples/streaming/AutoComplete.java  |  37 ++--
 .../flink/examples/streaming/JoinExamples.java  |  14 +-
 .../examples/streaming/KafkaIOExamples.java     |   7 +-
 .../KafkaWindowedWordCountExample.java          |  10 +-
 .../examples/streaming/WindowedWordCount.java   |  10 +-
 .../beam/runners/flink/ReadSourceITCase.java    |   6 +-
 .../flink/ReadSourceStreamingITCase.java        |   8 +-
 .../apache/beam/runners/spark/TfIdfTest.java    |  22 +--
 .../spark/translation/CombinePerKeyTest.java    |   6 +-
 .../translation/MultiOutputWordCountTest.java   |  10 +-
 .../spark/translation/SerializationTest.java    |  10 +-
 .../streaming/KafkaStreamingTest.java           |   6 +-
 .../main/java/org/apache/beam/sdk/io/Write.java |  26 +--
 .../org/apache/beam/sdk/transforms/Combine.java |  20 +-
 .../org/apache/beam/sdk/transforms/Filter.java  |   4 +-
 .../beam/sdk/transforms/windowing/Window.java   |   7 +-
 .../org/apache/beam/sdk/util/Reshuffle.java     |   6 +-
 .../java/org/apache/beam/sdk/io/WriteTest.java  |  22 ++-
 .../apache/beam/sdk/transforms/DoFnTest.java    |  29 +--
 .../apache/beam/sdk/transforms/ViewTest.java    | 192 ++++++++++---------
 .../beam/sdk/io/gcp/bigquery/BigQueryIO.java    |  21 +-
 .../sdk/transforms/WithTimestampsJava8Test.java |   6 +-
 24 files changed, 248 insertions(+), 264 deletions(-)
----------------------------------------------------------------------



Mime
View raw message