This closes #2363
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b7ddab28 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b7ddab28 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b7ddab28 Branch: refs/heads/DSL_SQL Commit: b7ddab2818cebb702ecb61a36fdb6c79c4a4956f Parents: f314354 831b11f Author: Eugene Kirpichov <[email protected]> Authored: Wed Apr 12 11:38:32 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Wed Apr 12 11:38:32 2017 -0700 ---------------------------------------------------------------------- .../beam/examples/MinimalWordCountJava8.java | 9 +- .../beam/examples/complete/game/GameStats.java | 6 +- .../beam/examples/complete/game/UserScore.java | 5 +- .../examples/MinimalWordCountJava8Test.java | 9 +- .../complete/game/HourlyTeamScoreTest.java | 5 +- .../examples/complete/game/UserScoreTest.java | 6 +- .../beam/runners/direct/DirectRunnerTest.java | 5 +- .../beam/sdk/transforms/FlatMapElements.java | 113 +++++++++---------- .../apache/beam/sdk/transforms/MapElements.java | 99 ++++++++-------- .../beam/sdk/transforms/MapElementsTest.java | 25 ++-- .../sdk/io/gcp/bigquery/BatchLoadBigQuery.java | 7 +- .../transforms/FlatMapElementsJava8Test.java | 10 +- .../sdk/transforms/MapElementsJava8Test.java | 10 +- 13 files changed, 153 insertions(+), 156 deletions(-) ----------------------------------------------------------------------
