This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to tag nightly-master in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! *** from 9c8939b (commit) to 6173abb (commit) from 9c8939b [BEAM-13082] Re-use dataWriter buffer. (#15762) add dc0548e Merge pull request #15761 from [BEAM-13008] Create gradle tasks for the Beam Playground add e6f7f44 [BEAM-13096] Double test timeout. (#15774) add 76f531f [BEAM-13019] Add `containsInAnyOrder` with matchers to the `IterableAssert` interface (#15685) add a4acdb8 [BEAM-11758] Update basics page: Pipeline, PCollection, PTransform (#15720) add 975d71a Test SetState addIfAbsent with no read (#15776) add 30d1191 Avoiding read-only Go module cache in Gradle config. add 8c143ab Merge pull request #15777: [BEAM-12830] Avoiding read-only Go module cache in Gradle config. add ca6f4f0 lazy creation of source splits for export-based ReadFromBigQuery (#15610) add 3d8213a [BEAM-11275] Support remote package download from remote filesystems in Stager (#15105) add 6173abb [BEAM-13015] Create a multiplexer that sends Elements based upon instruction id allowing for an inbound observer responsible for the entire instruction id. (#15747) No new revisions were added by this update. Summary of changes: .gitignore | 7 + CHANGES.md | 1 + build.gradle.kts | 13 +- playground/README.md | 57 +++ .../v1/playground.proto => api/v1/api.proto} | 6 +- playground/backend/build.gradle.kts | 52 +++ playground/backend/cmd/server/controller.go | 3 +- playground/backend/cmd/server/controller_test.go | 2 +- playground/backend/cmd/server/server.go | 11 +- playground/backend/go.sum | 55 +-- .../api/{playground.pb.go => v1/api.pb.go} | 338 ++++++++-------- .../{playground_grpc.pb.go => v1/api_grpc.pb.go} | 27 +- .../go_helper.go => environment/environment.go} | 17 +- playground/backend/internal/executors/executor.go | 2 +- playground/backend/internal/executors/go_helper.go | 2 + .../backend/internal/executors/java_helper_test.go | 2 +- playground/backend/internal/fs_tool/fs.go | 2 +- playground/backend/internal/fs_tool/fs_test.go | 2 +- playground/buf.gen.yaml | 32 ++ playground/build.gradle.kts | 30 ++ playground/frontend/README.md | 6 +- playground/frontend/analysis_options.yaml | 4 + playground/frontend/build.gradle.kts | 74 ++++ playground/frontend/lib/api/v1/api.pb.dart | 450 +++++++++++++++++++++ playground/frontend/lib/api/v1/api.pbenum.dart | 68 ++++ playground/frontend/lib/api/v1/api.pbgrpc.dart | 158 ++++++++ playground/frontend/lib/api/v1/api.pbjson.dart | 137 +++++++ .../code_client/grpc_code_client.dart | 2 +- .../code_repository_test.mocks.dart | 86 ++++ sdks/go/build.gradle | 13 + sdks/go/container/build.gradle | 13 + sdks/go/examples/build.gradle | 13 + sdks/go/test/build.gradle | 14 + sdks/go/test/load/build.gradle | 13 + sdks/go/test/run_validatesrunner_tests.sh | 2 +- sdks/java/container/build.gradle | 13 + .../java/org/apache/beam/sdk/testing/PAssert.java | 73 +++- .../java/org/apache/beam/sdk/io/FileIOTest.java | 10 +- .../org/apache/beam/sdk/testing/PAssertTest.java | 15 +- .../org/apache/beam/sdk/transforms/ParDoTest.java | 49 +++ .../sql/zetasql/ZetaSqlDialectSpecTest.java | 10 +- .../sdk/fn/data/BeamFnDataGrpcMultiplexer2.java | 274 +++++++++++++ .../sdk/fn/data/BeamFnDataInboundObserver2.java | 196 +++++++++ .../org/apache/beam/sdk/fn/data/DataEndpoint.java | 35 ++ .../org/apache/beam/sdk/fn/data/TimerEndpoint.java | 37 ++ .../fn/data/BeamFnDataGrpcMultiplexer2Test.java | 363 +++++++++++++++++ .../fn/data/BeamFnDataInboundObserver2Test.java | 249 ++++++++++++ sdks/python/apache_beam/io/gcp/bigquery.py | 6 +- .../runners/portability/artifact_service.py | 4 +- .../apache_beam/runners/portability/stager.py | 21 + .../apache_beam/runners/portability/stager_test.py | 55 +++ sdks/python/container/build.gradle | 13 + settings.gradle.kts | 3 + .../www/site/content/en/documentation/_index.md | 58 ++- .../www/site/content/en/documentation/basics.md | 236 +++++++---- 55 files changed, 3063 insertions(+), 371 deletions(-) create mode 100644 playground/README.md rename playground/{playground/v1/playground.proto => api/v1/api.proto} (96%) create mode 100644 playground/backend/build.gradle.kts rename playground/backend/internal/api/{playground.pb.go => v1/api.pb.go} (55%) rename playground/backend/internal/api/{playground_grpc.pb.go => v1/api_grpc.pb.go} (89%) copy playground/backend/internal/{executors/go_helper.go => environment/environment.go} (71%) create mode 100644 playground/buf.gen.yaml create mode 100644 playground/build.gradle.kts create mode 100644 playground/frontend/build.gradle.kts create mode 100644 playground/frontend/lib/api/v1/api.pb.dart create mode 100644 playground/frontend/lib/api/v1/api.pbenum.dart create mode 100644 playground/frontend/lib/api/v1/api.pbgrpc.dart create mode 100644 playground/frontend/lib/api/v1/api.pbjson.dart create mode 100644 playground/frontend/test/modules/editor/repository/code_repository/code_repository_test.mocks.dart create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer2.java create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2.java create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/DataEndpoint.java create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/TimerEndpoint.java create mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer2Test.java create mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver2Test.java