You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/06/27 17:31:09 UTC
[3/3] incubator-beam git commit: This closes #529
This closes #529
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9abd0926
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9abd0926
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9abd0926
Branch: refs/heads/master
Commit: 9abd0926ac471c178eb30eeb01c964f9ecbd9cce
Parents: 4f580f5 fc52a10
Author: bchambers <bc...@google.com>
Authored: Mon Jun 27 10:29:31 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Mon Jun 27 10:29:31 2016 -0700
----------------------------------------------------------------------
.../beam/examples/DebuggingWordCount.java | 2 +-
.../org/apache/beam/examples/WordCount.java | 4 +-
.../apache/beam/examples/complete/TfIdf.java | 3 +-
.../examples/complete/TopWikipediaSessions.java | 2 +-
.../examples/cookbook/DatastoreWordCount.java | 2 +-
.../beam/examples/cookbook/DeDupExample.java | 5 +-
.../beam/examples/cookbook/TriggerExample.java | 4 +-
.../beam/examples/complete/game/GameStats.java | 28 ++-
.../examples/complete/game/HourlyTeamScore.java | 5 +-
.../examples/complete/game/LeaderBoard.java | 8 +-
.../beam/runners/flink/examples/TFIDF.java | 3 +-
.../beam/runners/flink/examples/WordCount.java | 4 +-
.../flink/examples/streaming/AutoComplete.java | 9 +-
.../flink/examples/streaming/JoinExamples.java | 13 +-
.../KafkaWindowedWordCountExample.java | 2 +-
.../examples/streaming/WindowedWordCount.java | 3 +-
.../beam/runners/dataflow/DataflowRunner.java | 2 +-
.../DataflowPipelineTranslatorTest.java | 6 +-
.../runners/dataflow/DataflowRunnerTest.java | 18 +-
.../beam/runners/spark/SimpleWordCountTest.java | 3 +-
.../java/org/apache/beam/sdk/io/AvroIO.java | 53 +----
.../java/org/apache/beam/sdk/io/BigQueryIO.java | 43 +----
.../java/org/apache/beam/sdk/io/PubsubIO.java | 35 +---
.../main/java/org/apache/beam/sdk/io/Read.java | 29 +--
.../java/org/apache/beam/sdk/io/TextIO.java | 55 +-----
.../org/apache/beam/sdk/io/package-info.java | 6 +-
.../beam/sdk/transforms/windowing/Window.java | 42 ----
.../beam/sdk/io/AvroIOGeneratedClassTest.java | 192 +++++--------------
.../java/org/apache/beam/sdk/io/AvroIOTest.java | 5 +-
.../org/apache/beam/sdk/io/BigQueryIOTest.java | 82 +++-----
.../apache/beam/sdk/io/FileBasedSourceTest.java | 5 +-
.../org/apache/beam/sdk/io/PubsubIOTest.java | 4 -
.../java/org/apache/beam/sdk/io/TextIOTest.java | 37 +---
.../org/apache/beam/sdk/io/XmlSourceTest.java | 19 +-
.../beam/sdk/runners/TransformTreeTest.java | 4 +-
.../sdk/transforms/windowing/WindowTest.java | 6 +-
.../sdk/transforms/windowing/WindowingTest.java | 2 +-
.../src/main/java/DebuggingWordCount.java | 2 +-
.../src/main/java/WordCount.java | 4 +-
39 files changed, 183 insertions(+), 568 deletions(-)
----------------------------------------------------------------------