You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by re...@apache.org on 2018/04/25 16:23:17 UTC

[beam] 01/01: Merge pull request #4989: [BEAM-3979] Start completing the new DoFn vision: plumb context parameters into process functions.

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 <re...@google.com>
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
reuvenlax@apache.org.