You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by sc...@apache.org on 2019/01/23 16:41:57 UTC
[beam] branch master updated (26173a8 -> 21f4b54)
This is an automated email from the ASF dual-hosted git repository.
scott pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 26173a8 Merge pull request #7497: [BEAM-6351] Divide separate job for "smoke" load test suites
new 47ad785 Revert "[BEAM-2939] SplittableDoFn Java SDK API Changes (#6969)"
new 4fa1ac2 Do not revert Backlog and Backlogs
new 0c5df62 spotless
new 21f4b54 Merge pull request #7600: [BEAM-6354] Revert "[BEAM-2939] SplittableDoFn Java SDK API Changes (#6969)"
The 19631 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../fn-execution/src/main/proto/beam_fn_api.proto | 17 ++-----
.../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 ++----
.../splittabledofn/RestrictionTracker.java | 9 +---
.../transforms/splittabledofn/Restrictions.java | 29 ------------
.../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 +-
17 files changed, 39 insertions(+), 204 deletions(-)
delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/Restrictions.java