This closes #522
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/41faee4f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/41faee4f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/41faee4f Branch: refs/heads/master Commit: 41faee4f9cbe29ad6a80742789a0004abe59e684 Parents: 7745b92 4f050bf Author: bchambers <bchamb...@google.com> Authored: Thu Jun 23 22:55:46 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Thu Jun 23 22:55:46 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/examples/MinimalWordCount.java | 2 +- .../beam/examples/complete/AutoComplete.java | 4 +- .../apache/beam/examples/complete/TfIdf.java | 13 ++-- .../examples/complete/TopWikipediaSessions.java | 7 +- .../beam/examples/cookbook/FilterExamples.java | 3 +- .../beam/examples/cookbook/JoinExamples.java | 4 +- .../beam/examples/cookbook/TriggerExample.java | 2 +- .../beam/examples/complete/game/GameStats.java | 7 +- .../examples/complete/game/HourlyTeamScore.java | 4 +- .../examples/complete/game/LeaderBoard.java | 4 +- .../beam/examples/complete/game/UserScore.java | 2 +- .../complete/game/utils/WriteToBigQuery.java | 2 +- .../game/utils/WriteWindowedToBigQuery.java | 2 +- .../complete/game/HourlyTeamScoreTest.java | 2 +- .../beam/runners/flink/examples/TFIDF.java | 48 +++++++------- .../flink/examples/streaming/AutoComplete.java | 4 +- .../flink/examples/streaming/JoinExamples.java | 4 +- .../beam/runners/dataflow/DataflowRunner.java | 5 +- .../dataflow/internal/AssignWindows.java | 2 +- .../DataflowPipelineTranslatorTest.java | 6 +- .../sdk/io/BoundedReadFromUnboundedSource.java | 3 +- .../apache/beam/sdk/io/PubsubUnboundedSink.java | 24 +++---- .../beam/sdk/io/PubsubUnboundedSource.java | 5 +- .../org/apache/beam/sdk/testing/PAssert.java | 6 +- .../org/apache/beam/sdk/transforms/Combine.java | 48 +++++++------- .../org/apache/beam/sdk/transforms/Count.java | 2 +- .../beam/sdk/transforms/FlatMapElements.java | 2 +- .../org/apache/beam/sdk/transforms/Flatten.java | 2 +- .../org/apache/beam/sdk/transforms/Keys.java | 13 ++-- .../org/apache/beam/sdk/transforms/KvSwap.java | 15 ++--- .../apache/beam/sdk/transforms/MapElements.java | 2 +- .../apache/beam/sdk/transforms/PTransform.java | 7 +- .../org/apache/beam/sdk/transforms/ParDo.java | 70 +------------------- .../beam/sdk/transforms/RemoveDuplicates.java | 13 ++-- .../org/apache/beam/sdk/transforms/Values.java | 13 ++-- .../apache/beam/sdk/transforms/WithKeys.java | 15 ++--- .../beam/sdk/transforms/WithTimestamps.java | 2 +- .../beam/sdk/transforms/join/CoGroupByKey.java | 10 ++- .../beam/sdk/transforms/windowing/Window.java | 21 +++--- .../org/apache/beam/sdk/util/Reshuffle.java | 3 +- .../apache/beam/sdk/util/ValueWithRecordId.java | 19 ++---- .../apache/beam/sdk/transforms/ParDoTest.java | 27 ++------ .../sdk/transforms/windowing/WindowingTest.java | 8 +-- .../src/main/java/MinimalWordCount.java | 4 +- 44 files changed, 180 insertions(+), 281 deletions(-) ----------------------------------------------------------------------