Repository: beam Updated Branches: refs/heads/master 1d97bdffc -> 4fabaef80
Closes #2184 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4fabaef8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4fabaef8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4fabaef8 Branch: refs/heads/master Commit: 4fabaef806bc8842016c546fa955be8b28c921aa Parents: 1d97bdf 6f26db8 Author: bchambers <bchamb...@google.com> Authored: Tue Apr 25 09:20:26 2017 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Apr 25 12:45:33 2017 -0700 ---------------------------------------------------------------------- .../beam/examples/DebuggingWordCount.java | 20 +- .../org/apache/beam/examples/WordCount.java | 9 +- .../cookbook/CombinePerKeyExamples.java | 9 +- .../beam/examples/complete/game/GameStats.java | 8 +- .../beam/examples/complete/game/UserScore.java | 8 +- .../beam/runners/apex/ApexRunnerResult.java | 9 - .../runners/apex/examples/WordCountTest.java | 9 +- .../core/DoFnDelegatingAggregatorTest.java | 144 -------- .../beam/runners/core/OldDoFnContextTest.java | 72 ---- .../apache/beam/runners/core/OldDoFnTest.java | 32 -- .../beam/runners/direct/DirectRunner.java | 37 -- .../beam/runners/direct/DirectRunnerTest.java | 36 -- .../flink/FlinkDetachedRunnerResult.java | 11 - .../beam/runners/flink/FlinkRunnerResult.java | 21 -- .../runners/dataflow/DataflowPipelineJob.java | 27 -- .../dataflow/DataflowPipelineJobTest.java | 337 ------------------- .../beam/runners/spark/SparkPipelineResult.java | 7 - .../beam/runners/spark/examples/WordCount.java | 11 +- .../org/apache/beam/sdk/PipelineResult.java | 12 - 19 files changed, 34 insertions(+), 785 deletions(-) ----------------------------------------------------------------------
