This closes #57
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ac63fd6d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ac63fd6d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ac63fd6d Branch: refs/heads/master Commit: ac63fd6d4a2ce5ff0a6fe809fbe5f960ed71fa48 Parents: 659f0b8 a2a2c7b Author: Kenneth Knowles <k...@google.com> Authored: Thu Mar 17 13:26:05 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Mar 17 13:26:05 2016 -0700 ---------------------------------------------------------------------- examples/pom.xml | 127 ------ .../examples/MinimalWordCountJava8.java | 68 --- .../examples/complete/game/GameStats.java | 347 --------------- .../examples/complete/game/HourlyTeamScore.java | 193 --------- .../examples/complete/game/LeaderBoard.java | 237 ----------- .../dataflow/examples/complete/game/README.md | 119 ------ .../examples/complete/game/UserScore.java | 239 ----------- .../complete/game/injector/Injector.java | 417 ------------------- .../complete/game/injector/InjectorUtils.java | 101 ----- .../injector/RetryHttpInitializerWrapper.java | 127 ------ .../complete/game/utils/WriteToBigQuery.java | 134 ------ .../game/utils/WriteWindowedToBigQuery.java | 76 ---- .../examples/MinimalWordCountJava8Test.java | 103 ----- .../examples/complete/game/GameStatsTest.java | 99 ----- .../complete/game/HourlyTeamScoreTest.java | 121 ------ .../examples/complete/game/UserScoreTest.java | 156 ------- java8examples/pom.xml | 278 +++++++++++++ .../examples/MinimalWordCountJava8.java | 68 +++ .../examples/complete/game/GameStats.java | 339 +++++++++++++++ .../examples/complete/game/HourlyTeamScore.java | 193 +++++++++ .../examples/complete/game/LeaderBoard.java | 237 +++++++++++ .../dataflow/examples/complete/game/README.md | 113 +++++ .../examples/complete/game/UserScore.java | 239 +++++++++++ .../complete/game/injector/Injector.java | 415 ++++++++++++++++++ .../complete/game/injector/InjectorUtils.java | 101 +++++ .../injector/RetryHttpInitializerWrapper.java | 126 ++++++ .../complete/game/utils/WriteToBigQuery.java | 134 ++++++ .../game/utils/WriteWindowedToBigQuery.java | 76 ++++ .../examples/MinimalWordCountJava8Test.java | 103 +++++ .../examples/complete/game/GameStatsTest.java | 76 ++++ .../complete/game/HourlyTeamScoreTest.java | 111 +++++ .../examples/complete/game/UserScoreTest.java | 154 +++++++ java8tests/pom.xml | 183 ++++++++ .../sdk/transforms/CombineJava8Test.java | 133 ++++++ .../sdk/transforms/FilterJava8Test.java | 118 ++++++ .../transforms/FlatMapElementsJava8Test.java | 84 ++++ .../sdk/transforms/MapElementsJava8Test.java | 77 ++++ .../sdk/transforms/PartitionJava8Test.java | 74 ++++ .../transforms/RemoveDuplicatesJava8Test.java | 98 +++++ .../sdk/transforms/WithKeysJava8Test.java | 73 ++++ .../sdk/transforms/WithTimestampsJava8Test.java | 65 +++ pom.xml | 22 +- sdk/pom.xml | 73 +--- .../sdk/runners/DataflowPipelineRunner.java | 13 +- .../inprocess/FlattenEvaluatorFactory.java | 6 +- .../inprocess/GroupByKeyEvaluatorFactory.java | 7 +- .../inprocess/ParDoMultiEvaluatorFactory.java | 5 +- .../inprocess/ParDoSingleEvaluatorFactory.java | 5 +- .../runners/inprocess/ViewEvaluatorFactory.java | 7 +- .../dataflow/sdk/transforms/DoFnReflector.java | 7 +- .../cloud/dataflow/sdk/util/DoFnRunners.java | 4 +- .../sdk/transforms/CombineJava8Test.java | 133 ------ .../sdk/transforms/FilterJava8Test.java | 118 ------ .../transforms/FlatMapElementsJava8Test.java | 84 ---- .../sdk/transforms/MapElementsJava8Test.java | 77 ---- .../sdk/transforms/PartitionJava8Test.java | 74 ---- .../transforms/RemoveDuplicatesJava8Test.java | 99 ----- .../sdk/transforms/WithKeysJava8Test.java | 74 ---- .../sdk/transforms/WithTimestampsJava8Test.java | 66 --- 59 files changed, 3721 insertions(+), 3485 deletions(-) ----------------------------------------------------------------------
