beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [2/2] beam git commit: This closes #3360: [BEAM-2447] Reintroduces DoFn.ProcessContinuation
Date Wed, 12 Jul 2017 23:29:30 GMT
This closes #3360: [BEAM-2447] Reintroduces DoFn.ProcessContinuation


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

Branch: refs/heads/master
Commit: 66b4a1be09b58a761cf49cc18a04eaaff555e376
Parents: 91c7d3d 1bff4a7
Author: Eugene Kirpichov <kirpichov@google.com>
Authored: Wed Jul 12 16:16:05 2017 -0700
Committer: Eugene Kirpichov <kirpichov@google.com>
Committed: Wed Jul 12 16:16:05 2017 -0700

----------------------------------------------------------------------
 .../core/construction/SplittableParDoTest.java  |  10 +-
 ...eBoundedSplittableProcessElementInvoker.java |  35 ++++++-
 .../core/SplittableParDoViaKeyedWorkItems.java  |   9 +-
 .../core/SplittableProcessElementInvoker.java   |  25 ++++-
 ...ndedSplittableProcessElementInvokerTest.java |  45 +++++++--
 .../core/SplittableParDoProcessFnTest.java      |  99 ++++++++++++++++--
 .../org/apache/beam/sdk/transforms/DoFn.java    |  51 +++++++++-
 .../reflect/ByteBuddyDoFnInvokerFactory.java    |  19 +++-
 .../sdk/transforms/reflect/DoFnInvoker.java     |   4 +-
 .../sdk/transforms/reflect/DoFnSignature.java   |  10 +-
 .../sdk/transforms/reflect/DoFnSignatures.java  |  22 +++-
 .../splittabledofn/OffsetRangeTracker.java      |  10 ++
 .../splittabledofn/RestrictionTracker.java      |  11 +-
 .../beam/sdk/transforms/SplittableDoFnTest.java | 100 ++++++++-----------
 .../transforms/reflect/DoFnInvokersTest.java    |  93 +++++++++++++----
 .../DoFnSignaturesProcessElementTest.java       |   2 +-
 .../DoFnSignaturesSplittableDoFnTest.java       |  83 +++++++++++++--
 17 files changed, 487 insertions(+), 141 deletions(-)
----------------------------------------------------------------------



Mime
View raw message