beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [4/4] beam git commit: This closes #1636: Move OldDoFn to runners-core
Date Fri, 20 Jan 2017 22:38:37 GMT
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 <klk@google.com>
Authored: Fri Jan 20 14:22:38 2017 -0800
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message