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 2017/01/20 22:38:37 UTC
[4/4] beam git commit: This closes #1636: Move OldDoFn to runners-core
This closes #1636: Move OldDoFn to runners-core
Point to new Dataflow worker
Moves OldDoFn to runners-core
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a6810372
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a6810372
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a6810372
Branch: refs/heads/master
Commit: a6810372b003adf24bdbe34ed764a63841af9b99
Parents: 77c7505 a2b94ec
Author: Kenneth Knowles <kl...@google.com>
Authored: Fri Jan 20 14:22:38 2017 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Fri Jan 20 14:22:38 2017 -0800
----------------------------------------------------------------------
.../apex/translation/WindowBoundTranslator.java | 2 +-
.../operators/ApexGroupByKeyOperator.java | 2 +-
.../operators/ApexParDoOperator.java | 2 +-
.../beam/runners/core/AssignWindowsDoFn.java | 3 +-
.../apache/beam/runners/core/DoFnAdapters.java | 1 -
.../apache/beam/runners/core/DoFnRunner.java | 1 -
.../apache/beam/runners/core/DoFnRunners.java | 1 -
.../core/GroupAlsoByWindowViaWindowSetDoFn.java | 1 -
.../runners/core/GroupAlsoByWindowsDoFn.java | 1 -
.../core/LateDataDroppingDoFnRunner.java | 1 -
.../org/apache/beam/runners/core/OldDoFn.java | 472 +++++++++++++++++++
.../beam/runners/core/SimpleOldDoFnRunner.java | 3 +-
.../core/DoFnDelegatingAggregatorTest.java | 144 ++++++
.../apache/beam/runners/core/NoOpOldDoFn.java | 72 +++
.../beam/runners/core/OldDoFnContextTest.java | 72 +++
.../apache/beam/runners/core/OldDoFnTest.java | 192 ++++++++
.../runners/core/SimpleOldDoFnRunnerTest.java | 2 +-
.../runners/flink/OldPerKeyCombineFnRunner.java | 2 +-
.../flink/OldPerKeyCombineFnRunners.java | 2 +-
.../functions/FlinkDoFnFunction.java | 2 +-
.../FlinkMergingNonShuffleReduceFunction.java | 2 +-
.../functions/FlinkMultiOutputDoFnFunction.java | 2 +-
.../FlinkMultiOutputProcessContext.java | 2 +-
.../functions/FlinkNoElementAssignContext.java | 2 +-
.../functions/FlinkPartialReduceFunction.java | 2 +-
.../functions/FlinkProcessContextBase.java | 2 +-
.../functions/FlinkReduceFunction.java | 2 +-
.../FlinkSingleOutputProcessContext.java | 2 +-
.../wrappers/streaming/DoFnOperator.java | 2 +-
.../wrappers/streaming/WindowDoFnOperator.java | 2 +-
.../beam/runners/dataflow/util/DoFnInfo.java | 4 +-
.../beam/runners/dataflow/dataflow.properties | 4 +-
.../sdk/transforms/DelegatingAggregator.java | 2 +-
.../org/apache/beam/sdk/transforms/OldDoFn.java | 465 ------------------
.../org/apache/beam/sdk/util/NameUtils.java | 2 +-
.../DoFnDelegatingAggregatorTest.java | 142 ------
.../apache/beam/sdk/transforms/NoOpOldDoFn.java | 71 ---
.../beam/sdk/transforms/OldDoFnContextTest.java | 69 ---
.../apache/beam/sdk/transforms/OldDoFnTest.java | 187 --------
.../org/apache/beam/sdk/util/NameUtilsTest.java | 20 +-
40 files changed, 984 insertions(+), 980 deletions(-)
----------------------------------------------------------------------