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 <k...@google.com> Authored: Fri Dec 16 18:46:17 2016 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------
