This closes #2851
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/34d25f40 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/34d25f40 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/34d25f40 Branch: refs/heads/master Commit: 34d25f4069631e43b19a86a06b4a491e524fc1d5 Parents: f3f8810 878981f Author: Dan Halperin <dhalp...@google.com> Authored: Wed May 3 20:52:41 2017 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Wed May 3 20:52:41 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/examples/WindowedWordCount.java | 2 +- .../operators/ApexParDoOperator.java | 1 - .../apache/beam/runners/core/DoFnRunners.java | 21 ------------ .../functions/FlinkDoFnFunction.java | 1 - .../functions/FlinkStatefulDoFnFunction.java | 1 - .../wrappers/streaming/DoFnOperator.java | 1 - .../apache/beam/sdk/transforms/Aggregator.java | 34 -------------------- .../org/apache/beam/sdk/transforms/Latest.java | 15 +-------- .../beam/sdk/util/SystemDoFnInternal.java | 3 -- .../sdk/transforms/ApproximateUniqueTest.java | 2 +- .../beam/sdk/transforms/DoFnTesterTest.java | 2 +- .../beam/sdk/transforms/LatestFnTest.java | 2 +- 12 files changed, 5 insertions(+), 80 deletions(-) ----------------------------------------------------------------------
