[beam] branch master updated (c754c0b7129 -> 7d5d62e1ebf)

[lc...@apache.org]

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 c754c0b7129 Bump github.com/aws/aws-sdk-go-v2/config from 1.18.4 to 1.18.5 in /sdks (#24688)
     add 7d5d62e1ebf Add MultimapState API (#23491)

No new revisions were added by this update.

Summary of changes:
 .../beam/model/pipeline/v1/beam_runner_api.proto   |   6 +
 .../core/construction/ParDoTranslation.java        |  11 +
 .../beam/runners/core/InMemoryStateInternals.java  | 192 +++++++-
 .../org/apache/beam/runners/core/StateTag.java     |   4 +
 .../org/apache/beam/runners/core/StateTags.java    |  15 +
 .../direct/CopyOnAccessInMemoryStateInternals.java |  26 ++
 runners/flink/flink_runner.gradle                  |   1 +
 runners/flink/job-server/flink_job_server.gradle   |   2 +-
 .../state/FlinkBroadcastStateInternals.java        |  10 +
 .../streaming/state/FlinkStateInternals.java       |  21 +
 runners/google-cloud-dataflow-java/build.gradle    |   1 +
 .../beam/runners/dataflow/DataflowRunner.java      |   7 +
 .../dataflow/worker/WindmillStateInternals.java    |  10 +
 runners/jet/build.gradle                           |   1 +
 runners/portability/java/build.gradle              |   1 +
 runners/samza/build.gradle                         |   1 +
 .../samza/runtime/SamzaStoreStateInternals.java    |  10 +
 runners/spark/job-server/spark_job_server.gradle   |   1 +
 runners/spark/spark_runner.gradle                  |   2 +
 .../spark/stateful/SparkStateInternals.java        |  10 +
 .../org/apache/beam/sdk/state/MultimapState.java   |  87 ++++
 .../org/apache/beam/sdk/state/StateBinder.java     |   6 +
 .../java/org/apache/beam/sdk/state/StateSpec.java  |   7 +
 .../java/org/apache/beam/sdk/state/StateSpecs.java | 107 ++++-
 ...sFailureMessage.java => UsesMultimapState.java} |   8 +-
 .../java/org/apache/beam/sdk/transforms/ParDo.java |   5 +
 .../sdk/transforms/reflect/DoFnSignatures.java     |   5 +
 .../org/apache/beam/sdk/transforms/ParDoTest.java  | 515 +++++++++++++++++++++
 .../beam/fn/harness/state/FnApiStateAccessor.java  |  11 +
 29 files changed, 1053 insertions(+), 30 deletions(-)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/state/MultimapState.java
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesFailureMessage.java => UsesMultimapState.java} (82%)