Closes #781
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/74c5e5e1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/74c5e5e1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/74c5e5e1 Branch: refs/heads/python-sdk Commit: 74c5e5e1b546759a082d4e4785d46f9d56fa1052 Parents: 734bfb9 71e027d Author: Dan Halperin <[email protected]> Authored: Thu Aug 4 11:54:31 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Thu Aug 4 11:54:31 2016 -0700 ---------------------------------------------------------------------- .../examples/complete/StreamingWordExtract.java | 18 ++++++------ .../apache/beam/examples/complete/TfIdf.java | 28 +++++++++--------- .../examples/complete/TopWikipediaSessions.java | 31 +++++++++----------- .../examples/complete/TrafficMaxLaneFlow.java | 16 +++++----- .../beam/examples/complete/TrafficRoutes.java | 20 ++++++------- .../examples/cookbook/BigQueryTornadoes.java | 10 +++---- .../cookbook/CombinePerKeyExamples.java | 10 +++---- .../examples/cookbook/DatastoreWordCount.java | 14 ++++----- .../beam/examples/cookbook/FilterExamples.java | 20 ++++++------- .../beam/examples/cookbook/JoinExamples.java | 18 ++++++------ .../examples/cookbook/MaxPerKeyExamples.java | 10 +++---- .../beam/examples/cookbook/TriggerExample.java | 25 ++++++++-------- .../org/apache/beam/examples/WordCountTest.java | 3 +- .../examples/complete/AutoCompleteTest.java | 6 ++-- .../examples/cookbook/TriggerExampleTest.java | 6 ++-- .../beam/examples/complete/game/GameStats.java | 22 +++++++------- .../beam/examples/complete/game/UserScore.java | 6 ++-- .../examples/complete/game/UserScoreTest.java | 2 +- 18 files changed, 130 insertions(+), 135 deletions(-) ----------------------------------------------------------------------
