You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/03/17 21:47:40 UTC
[8/8] incubator-beam git commit: This closes #57
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 <kl...@google.com>
Authored: Thu Mar 17 13:26:05 2016 -0700
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------