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/24 06:21:20 UTC
[3/3] incubator-beam git commit: This closes #522
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 <bc...@google.com>
Authored: Thu Jun 23 22:55:46 2016 -0700
Committer: bchambers <bc...@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(-)
----------------------------------------------------------------------