You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2018/11/30 17:40:21 UTC
[beam] branch master updated (bd81e8b -> d136637)
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from bd81e8b Merge pull request #7126: [BEAM-3659] Port UserScoreTest off DoFnTester
add d136637 [BEAM-2939] SplittableDoFn Java SDK API Changes (#6969)
No new revisions were added by this update.
Summary of changes:
.../fn-execution/src/main/proto/beam_fn_api.proto | 16 +++-
.../runners/core/construction/SplittableParDo.java | 2 +
.../construction/SplittableParDoNaiveBounded.java | 4 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 7 +-
.../runners/core/SplittableParDoProcessFnTest.java | 18 +++++
.../direct/portable/ReferenceRunnerTest.java | 3 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 49 +++++++++---
.../reflect/ByteBuddyDoFnInvokerFactory.java | 6 +-
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 2 +
.../sdk/transforms/reflect/DoFnSignatures.java | 13 +++-
.../sdk/transforms/splittabledofn/Backlog.java | 90 ++++++++++++++++++++++
.../sdk/transforms/splittabledofn/Backlogs.java | 58 ++++++++++++++
.../splittabledofn/RestrictionTracker.java | 9 ++-
.../{package-info.java => Restrictions.java} | 17 ++--
.../beam/sdk/transforms/SplittableDoFnTest.java | 5 +-
.../sdk/transforms/reflect/DoFnInvokersTest.java | 20 ++++-
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 52 +++++++++++--
.../harness/SplittableProcessElementsRunner.java | 4 +-
.../beam/sdk/io/hbase/HBaseReadSplittableDoFn.java | 3 +-
19 files changed, 332 insertions(+), 46 deletions(-)
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/Backlog.java
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/Backlogs.java
copy sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/{package-info.java => Restrictions.java} (69%)