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 <[email protected]> Authored: Mon Jun 27 10:29:31 2016 -0700 Committer: bchambers <[email protected]> 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(-) ----------------------------------------------------------------------
