[beam] branch nightly-refs/heads/master updated (4886bdf08fd -> 635b277e1e1)

[gi...@apache.org]

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

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 4886bdf08fd [CdapIO] Complete examples for CDAP Zendesk plugins (#24589)
     add 4a0932d5cac Bump github.com/aws/aws-sdk-go-v2 from 1.17.2 to 1.17.3 in /sdks (#24686)
     add 7c691b7449f [Tour Of Beam] delete user progress (#24657)
     add 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)
     add 635b277e1e1 sickbay test (#24681)

No new revisions were added by this update.

Summary of changes:
 .../workflows/tour_of_beam_backend_integration.yml |   3 +
 learning/tour-of-beam/backend/README.md            |   6 +
 learning/tour-of-beam/backend/auth.go              |  16 +-
 learning/tour-of-beam/backend/function.go          |  36 +-
 .../backend/integration_tests/auth_test.go         |  26 ++
 .../backend/integration_tests/client.go            |   7 +
 .../backend/integration_tests/function_test.go     |  13 +-
 .../backend/integration_tests/local.sh             |   2 +
 .../backend/internal/service/content.go            |   5 +
 .../backend/internal/storage/datastore.go          |  28 ++
 .../tour-of-beam/backend/internal/storage/iface.go |   2 +
 .../tour-of-beam/backend/internal/storage/mock.go  |   4 +
 learning/tour-of-beam/backend/middleware.go        |  25 +-
 .../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 +
 sdks/go.mod                                        |  22 +-
 sdks/go.sum                                        |  33 +-
 .../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 +
 .../dataflow_exercise_metrics_pipeline_test.py     |   1 +
 45 files changed, 1237 insertions(+), 75 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%)