beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [5/5] incubator-beam git commit: This closes #1648: Undeletes DoFnInvokers.of(OldDoFn)
Date Sat, 17 Dec 2016 03:45:33 GMT
This closes #1648: Undeletes DoFnInvokers.of(OldDoFn)

  Revert "Move InMemoryTimerInternals to runners-core"
  Revert "Moves DoFnAdapters to runners-core"
  Revert "Removes ArgumentProvider.windowingInternals"
  Revert "Removes code for wrapping DoFn as an OldDoFn"


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ffe3ab3d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ffe3ab3d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ffe3ab3d

Branch: refs/heads/master
Commit: ffe3ab3d622c767871064dcdb8c5a953bbf0a1d2
Parents: 7d1976b 45ed5c7
Author: Kenneth Knowles <klk@google.com>
Authored: Fri Dec 16 18:46:17 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Fri Dec 16 18:46:17 2016 -0800

----------------------------------------------------------------------
 .../apex/translation/WindowBoundTranslator.java |   2 +-
 .../operators/ApexGroupByKeyOperator.java       |   2 +-
 .../operators/ApexParDoOperator.java            |   2 +-
 .../apache/beam/runners/core/DoFnAdapters.java  | 344 -------------
 .../GroupAlsoByWindowsViaOutputBufferDoFn.java  |   1 +
 .../runners/core/InMemoryTimerInternals.java    | 276 ----------
 .../beam/runners/core/SimpleDoFnRunner.java     |  57 +++
 .../beam/runners/core/SimpleOldDoFnRunner.java  |   4 +-
 .../beam/runners/core/SplittableParDo.java      |   7 +
 .../core/GroupAlsoByWindowsProperties.java      |   2 +-
 .../core/InMemoryTimerInternalsTest.java        | 155 ------
 .../beam/runners/core/ReduceFnTester.java       |   1 +
 .../beam/runners/core/SplittableParDoTest.java  |  16 +-
 .../triggers/TriggerStateMachineTester.java     |   2 +-
 .../functions/FlinkDoFnFunction.java            |   2 +-
 .../functions/FlinkMultiOutputDoFnFunction.java |   2 +-
 .../functions/FlinkProcessContextBase.java      |   2 +-
 .../wrappers/streaming/DoFnOperator.java        |   2 +-
 .../translation/SparkGroupAlsoByWindowFn.java   |   2 +-
 .../sdk/transforms/AggregatorRetriever.java     |  13 +-
 .../beam/sdk/transforms/DoFnAdapters.java       | 504 +++++++++++++++++++
 .../apache/beam/sdk/transforms/DoFnTester.java  |  43 ++
 .../org/apache/beam/sdk/transforms/OldDoFn.java | 297 ++++++++++-
 .../sdk/transforms/reflect/DoFnInvoker.java     |  20 +
 .../sdk/transforms/reflect/DoFnInvokers.java    | 141 +++++-
 .../sdk/util/state/InMemoryTimerInternals.java  | 275 ++++++++++
 .../apache/beam/sdk/transforms/NoOpOldDoFn.java |   2 +-
 .../transforms/reflect/DoFnInvokersTest.java    |  42 ++
 .../util/state/InMemoryTimerInternalsTest.java  | 153 ++++++
 29 files changed, 1547 insertions(+), 824 deletions(-)
----------------------------------------------------------------------



Mime
View raw message