This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 82a0ae385803ca0d12b85a302d13eb68361a1cda Merge: 7a48f62 e62d997 Author: reuvenlax <[email protected]> AuthorDate: Wed Apr 25 09:23:09 2018 -0700 Merge pull request #4989: [BEAM-3979] Start completing the new DoFn vision: plumb context parameters into process functions. .../runners/core/construction/SplittableParDo.java | 14 +- ...TimeBoundedSplittableProcessElementInvoker.java | 37 ++ .../apache/beam/runners/core/SimpleDoFnRunner.java | 139 +++++++ .../java/org/apache/beam/sdk/transforms/DoFn.java | 46 ++- .../beam/sdk/transforms/DoFnOutputReceivers.java | 84 ++++ .../org/apache/beam/sdk/transforms/DoFnTester.java | 68 ++++ .../java/org/apache/beam/sdk/transforms/ParDo.java | 23 +- .../reflect/ByteBuddyDoFnInvokerFactory.java | 68 +++- .../beam/sdk/transforms/reflect/DoFnInvoker.java | 79 ++++ .../beam/sdk/transforms/reflect/DoFnSignature.java | 150 +++++++- .../sdk/transforms/reflect/DoFnSignatures.java | 63 ++- .../org/apache/beam/sdk/transforms/ParDoTest.java | 421 ++++++++++++--------- .../sdk/transforms/reflect/DoFnInvokersTest.java | 58 ++- .../sdk/transforms/reflect/DoFnSignaturesTest.java | 109 +++++- .../apache/beam/fn/harness/FnApiDoFnRunner.java | 104 +++++ 15 files changed, 1254 insertions(+), 209 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
