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 2021/10/25 22:12:07 UTC
[beam] branch master updated (e1b83ba -> fd4eb15)

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 e1b83ba  [BEAM-8543] Fix test filtering for Dataflow Runner V2 to exclude UsesStrictTimerOrdering
     add 9cfcfbe  [BEAM-12522] Enable side inputs on all splittable DoFn execution time related methods for portable runners.
     add fd4eb15  [BEAM-12522] Enable side inputs on all splittable DoFn execution time related methods.

No new revisions were added by this update.

Summary of changes:
 .../runners/core/construction/SplittableParDo.java |  79 +++++--
 .../construction/SplittableParDoNaiveBounded.java  |  49 ++++-
 ...TimeBoundedSplittableProcessElementInvoker.java |  13 +-
 .../core/SplittableParDoViaKeyedWorkItems.java     |  74 +++++--
 .../core/SplittableProcessElementInvoker.java      |   5 +-
 ...BoundedSplittableProcessElementInvokerTest.java |   4 +-
 .../runners/core/SplittableParDoProcessFnTest.java |   4 +-
 .../SplittableProcessElementsEvaluatorFactory.java |   9 +-
 runners/flink/job-server/flink_job_server.gradle   |   1 -
 .../wrappers/streaming/SplittableDoFnOperator.java |   1 +
 runners/google-cloud-dataflow-java/build.gradle    |   1 -
 .../worker/SplittableProcessFnFactory.java         |   4 +-
 runners/samza/job-server/build.gradle              |   1 -
 .../SplittableParDoProcessKeyedElementsOp.java     |   1 +
 runners/spark/job-server/spark_job_server.gradle   |   2 -
 .../UsesSplittableParDoWithWindowedSideInputs.java |  28 ---
 .../beam/sdk/transforms/reflect/DoFnSignature.java |   7 +-
 .../sdk/transforms/reflect/DoFnSignatures.java     |  21 +-
 .../beam/sdk/transforms/SplittableDoFnTest.java    | 233 +++++++++++++++++----
 .../reflect/DoFnSignaturesSplittableDoFnTest.java  |  21 +-
 20 files changed, 418 insertions(+), 140 deletions(-)
 delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSplittableParDoWithWindowedSideInputs.java