[beam] branch nightly-refs/heads/master updated (2c8e7eb7a39 -> 8a32df19e2c)

[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 2c8e7eb7a39 Move Xlang Go examples to generic registration (#22249)
     add b4c251a15bb Move Go Primitives Integration Tests to Generic Registration (#22247)
     add fa5bcfa3613 Move native Go examples to generic registration (#22245)
     add 9cf8cf5abfd Move youngoli to the reviewer exclusion list (#22195)
     add 51ed8db8bf0 Bump google.golang.org/api from 0.86.0 to 0.87.0 in /sdks (#22253)
     add f88b9ec0bc9 Bump cloud.google.com/go/bigquery from 1.34.1 to 1.35.0 in /sdks (#22213)
     add d54841c985f Bump google.golang.org/grpc from 1.47.0 to 1.48.0 in /sdks (#22252)
     add b78a080e932 Merge pull request #15786: Add gap-filling transform for timeseries
     add 7efd5940bdf [BEAM-14506] Adding testcases and examples for xlang Python RunInference
     add d5cec82adbe update
     add 1dc015fdf45 update
     add 316dfae2c5f Merge pull request #21809 from ihji/BEAM-14506
     add 48c081e5604 Defocus iframe on blur or mouseout (#22153) (#22154)
     add 95749737555 Fix pydoc rendering for annotated classes (#22121)
     add e69ada95f1f Adds an experiment that allows opting into using Kafka SDF-wrapper
     add f2e41be4880 Merge pull request #22251: Adds an experiment that allows opting into using Kafka SDF-wrapper
     add 8a32df19e2c Fix typo in comment (#22266)

No new revisions were added by this update.

Summary of changes:
 .github/REVIEWERS.yml                              |   4 +-
 .github/autolabeler.yml                            |   1 +
 build.gradle.kts                                   |   1 +
 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   5 +-
 playground/frontend/lib/constants/params.dart      |   2 +-
 playground/frontend/lib/main.dart                  |   2 +
 playground/frontend/lib/pages/routes.dart          |   2 +-
 playground/frontend/pubspec.lock                   |  42 ++
 playground/frontend/pubspec.yaml                   |   1 +
 .../runners/core/construction/SplittableParDo.java |   4 +-
 .../core/construction/SplittableParDoTest.java     |  32 +-
 runners/google-cloud-dataflow-java/build.gradle    |   1 +
 sdks/go.mod                                        |   8 +-
 sdks/go.sum                                        |  14 +-
 .../examples/complete/autocomplete/autocomplete.go |   6 +-
 sdks/go/examples/contains/contains.go              |   9 +-
 .../debugging_wordcount/debugging_wordcount.go     |   9 +-
 sdks/go/examples/grades/grades.go                  |  13 +-
 sdks/go/examples/kafka/taxi.go                     |   4 +-
 .../go/examples/large_wordcount/large_wordcount.go |  21 +-
 sdks/go/examples/multiout/multiout.go              |   6 +-
 sdks/go/examples/pingpong/pingpong.go              |  10 +-
 sdks/go/examples/stringsplit/stringsplit.go        |   7 +-
 .../windowed_wordcount/windowed_wordcount.go       |   6 +-
 sdks/go/examples/wordcount/wordcount.go            |   6 +-
 sdks/go/examples/yatzy/yatzy.go                    |   8 +-
 .../test/integration/primitives/checkpointing.go   |   5 +-
 sdks/go/test/integration/primitives/drain.go       |  17 +-
 sdks/go/test/integration/primitives/pardo.go       |  15 +-
 .../go/test/integration/primitives/window_panes.go |   5 +-
 sdks/go/test/integration/primitives/windowinto.go  |  12 +-
 .../coders/{MapCoder.java => SortedMapCoder.java}  |  47 +-
 .../beam/sdk/schemas/transforms/WithKeys.java      |  79 +++
 .../extensions/python/transforms/RunInference.java | 102 ++++
 ...ormTest.java => RunInferenceTransformTest.java} |  38 +-
 .../{join-library => timeseries}/build.gradle      |   5 +-
 .../beam/sdk/extensions/timeseries/FillGaps.java   | 535 +++++++++++++++++++++
 .../sdk/extensions/timeseries}/package-info.java   |   4 +-
 .../sdk/extensions/timeseries/FillGapsTest.java    | 355 ++++++++++++++
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  10 +-
 sdks/python/apache_beam/io/fileio.py               |   9 +-
 sdks/python/apache_beam/ml/inference/base.py       |   2 +-
 .../runners/portability/expansion_service_test.py  |  30 +-
 sdks/python/apache_beam/utils/annotations.py       |  93 ++--
 settings.gradle.kts                                |   1 +
 45 files changed, 1428 insertions(+), 160 deletions(-)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/coders/{MapCoder.java => SortedMapCoder.java} (75%)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/WithKeys.java
 create mode 100644 sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/transforms/RunInference.java
 copy sdks/java/extensions/python/src/test/java/org/apache/beam/sdk/extensions/python/transforms/{DataframeTransformTest.java => RunInferenceTransformTest.java} (51%)
 copy sdks/java/extensions/{join-library => timeseries}/build.gradle (86%)
 create mode 100644 sdks/java/extensions/timeseries/src/main/java/org/apache/beam/sdk/extensions/timeseries/FillGaps.java
 copy {examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro => sdks/java/extensions/timeseries/src/main/java/org/apache/beam/sdk/extensions/timeseries}/package-info.java (88%)
 create mode 100644 sdks/java/extensions/timeseries/src/test/java/org/apache/beam/sdk/extensions/timeseries/FillGapsTest.java