You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/10/22 04:19:07 UTC
[beam] tag nightly-master updated (9c8939b -> 6173abb)
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