You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2025/05/21 14:21:11 UTC

(beam) branch master updated (9eb7b988d23 -> 060cc1a91bc)

This is an automated email from the ASF dual-hosted git repository.

kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 9eb7b988d23 Upgrade to GCP-BOM 26.60.0 (#34975)
     add 910b38cf74f Annotate DoFnSignature methods as @Pure
     add 3b09453db15 Refactor: separate SplittableSplitAndSizeRestriction
     new 060cc1a91bc Merge pull request #34919: Refactor: separate SplitAndSizeRestriction from FnApiDoFnRunner

The 1 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:
 .../java/org/apache/beam/sdk/transforms/DoFn.java  |  10 +-
 .../beam/sdk/transforms/reflect/DoFnInvoker.java   |  11 +-
 .../beam/sdk/transforms/reflect/DoFnSignature.java |  30 ++
 sdks/java/harness/build.gradle                     |   1 -
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    | 150 +-----
 .../fn/harness/SplitResultsWithStopIndex.java}     |  32 +-
 .../SplittablePairWithRestrictionDoFnRunner.java   |  44 +-
 ...littableSplitAndSizeRestrictionsDoFnRunner.java | 462 +++++++++++++++++++
 .../beam/fn/harness/WindowedSplitResult.java}      |  43 +-
 .../beam/fn/harness/state/FnApiStateAccessor.java  |  27 +-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       | 369 ---------------
 ...ableSplitAndSizeRestrictionsDoFnRunnerTest.java | 509 +++++++++++++++++++++
 12 files changed, 1102 insertions(+), 586 deletions(-)
 copy sdks/java/{core/src/main/java/org/apache/beam/sdk/schemas/FieldValueSetter.java => harness/src/main/java/org/apache/beam/fn/harness/SplitResultsWithStopIndex.java} (59%)
 create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittableSplitAndSizeRestrictionsDoFnRunner.java
 copy sdks/java/{core/src/main/java/org/apache/beam/sdk/schemas/io/Failure.java => harness/src/main/java/org/apache/beam/fn/harness/WindowedSplitResult.java} (50%)
 create mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/SplittableSplitAndSizeRestrictionsDoFnRunnerTest.java

(beam) 01/01: Merge pull request #34919: Refactor: separate SplitAndSizeRestriction from FnApiDoFnRunner

Posted by ke...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 060cc1a91bc60db7fb3f5491b1133bd151a0da6d
Merge: 9eb7b988d23 3b09453db15
Author: Kenneth Knowles <ke...@apache.org>
AuthorDate: Wed May 21 10:21:03 2025 -0400

    Merge pull request #34919: Refactor: separate SplitAndSizeRestriction from FnApiDoFnRunner

 .../java/org/apache/beam/sdk/transforms/DoFn.java  |  10 +-
 .../beam/sdk/transforms/reflect/DoFnInvoker.java   |  11 +-
 .../beam/sdk/transforms/reflect/DoFnSignature.java |  30 ++
 sdks/java/harness/build.gradle                     |   1 -
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    | 150 +-----
 .../beam/fn/harness/SplitResultsWithStopIndex.java |  41 ++
 .../SplittablePairWithRestrictionDoFnRunner.java   |  44 +-
 ...littableSplitAndSizeRestrictionsDoFnRunner.java | 462 +++++++++++++++++++
 .../beam/fn/harness/WindowedSplitResult.java       |  49 ++
 .../beam/fn/harness/state/FnApiStateAccessor.java  |  27 +-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       | 369 ---------------
 ...ableSplitAndSizeRestrictionsDoFnRunnerTest.java | 509 +++++++++++++++++++++
 12 files changed, 1153 insertions(+), 550 deletions(-)