beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [4/4] incubator-beam git commit: This closes #1309
Date Thu, 10 Nov 2016 22:18:24 GMT
This closes #1309


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

Branch: refs/heads/master
Commit: 3f8db06bd2d35ea736d7c51df2c114f5cf4127f4
Parents: f7745dc 14a71e4
Author: Kenneth Knowles <klk@google.com>
Authored: Thu Nov 10 14:18:08 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
Committed: Thu Nov 10 14:18:08 2016 -0800

----------------------------------------------------------------------
 .../beam/runners/core/SimpleDoFnRunner.java     |   4 +-
 .../beam/runners/core/SplittableParDo.java      |  12 +-
 .../runners/direct/DoFnLifecycleManager.java    |   4 +-
 .../runners/direct/ParDoOverrideFactory.java    |   2 +-
 .../beam/sdk/transforms/DoFnAdapters.java       |   6 +-
 .../org/apache/beam/sdk/transforms/ParDo.java   |   6 +-
 .../reflect/ByteBuddyDoFnInvokerFactory.java    | 828 +++++++++++++++++++
 .../reflect/ByteBuddyOnTimerInvokerFactory.java | 279 +++++++
 .../transforms/reflect/DoFnInvokerFactory.java  |  27 +
 .../sdk/transforms/reflect/DoFnInvokers.java    | 711 +---------------
 .../sdk/transforms/reflect/DoFnSignatures.java  |  11 +-
 .../reflect/OnTimerInvokerFactory.java          |  36 +
 .../sdk/transforms/reflect/OnTimerInvokers.java | 243 +-----
 .../transforms/reflect/DoFnInvokersTest.java    |  24 +-
 .../DoFnSignaturesProcessElementTest.java       |  12 +-
 .../DoFnSignaturesSplittableDoFnTest.java       |  34 +-
 .../transforms/reflect/DoFnSignaturesTest.java  |  66 +-
 .../transforms/reflect/OnTimerInvokersTest.java |   2 +-
 .../transforms/DoFnInvokersBenchmark.java       |   2 +-
 19 files changed, 1295 insertions(+), 1014 deletions(-)
----------------------------------------------------------------------



Mime
View raw message