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 8da177f Merge pull request #15904: Raise an exception before trying
to launch a pipeline using BundleFinalizers on dataflow when runnerv2 is not in
use
add 2e0783f Initial add for terraform scripts for infra provision
add 562704e Add licenses
add 912efe7 Add beam playground applications deploy
add 74565fd Remove wrongly added log file
add 6b5daab Added readme file
add 0497975 Merge remote-tracking branch 'origin/master' into
BEAM-12940-Infra-Deploy
add 293fda2 Add license to README and added reader access to bucket
add a13da07 Remove trailing whitespace
add f0d3d9d [BEAM-12940][Playground] Infrastructure Deployment scripts
#15793
add 43a5f67 Add workflow to build backend application
add 7dcf46d Add license
add 5f69cf6 [BEAM-13172][Playground] Backend Application CI/CD scripts
#15870
add 973e533 Add frontend workflow
add 2f1d780 [BEAM-13173][Playground] Frontend Application CI/CD Scripts
#15878
add 77ea3ab for existing tables, no need to set a schema
add 8b81ab6 Merge pull request #15929 from [BEAM-2791] For existing
BigQuery tables, no need to set a schema.
add 0cff1ff [BEAM-13190] Elide trailing nils (#15920)
add ba5896a Initial add for dockerfiles and build scripts
add 48e9a2e Merge remote-tracking branch 'origin/master' into
BEAM-12939_backend_dockercontainer
add 82f6d22 Add fixes to docker plugin and also build arg for beam sdk
image
add e55b229 Remove wrongly added comments
add 1e8ae35 Fix syntax
add b077aa7 Added default values
add 5f3e568 Add default value to base image
add 3021b7e Added Beam Version as build arg, also changed way of getting
tags for image
add 03d4e42 Remove comment from dockerfile
add 9a44c9e [BEAM-12939][Playground] Backend app - Docker container #15751
add 19d3795 [BEAM-13052] Increment protobuf version to 3.19.0 (#15883)
add 1a572cf [BEAM-3304] refactoring trigger package in GoSDK (#15933)
add ad5a2eb [BEAM-13001] Hook to configure sampling period for DoFn
metric collection in Go SDK (#15928)
add 273613d [BEAM-3293] Add MultiMap side input decomposition (#15934)
add 03daa4f remove unused future / futures dependencies
add 415cc24 remove unused future / futures dependencies #15866
add 8d34bd8 [BEAM-12651] Exclude packages from jacoco report (#15792)
No new revisions were added by this update.
Summary of changes:
.github/workflows/build_playground_backend.yml | 73 ++++++++++++++
.github/workflows/build_playground_frontend.yml | 77 +++++++++++++++
.gitignore | 8 +-
.test-infra/jenkins/job_PreCommit_Java.groovy | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 27 ++++++
ownership/PYTHON_DEPENDENCY_OWNERS.yaml | 6 --
playground/backend/containers/java/Dockerfile | 38 +++++++-
playground/backend/containers/java/app.yaml | 22 +++++
playground/backend/containers/java/build.gradle | 66 +++++++++++++
playground/backend/containers/java/settings.gradle | 19 ++++
playground/backend/env_setup.sh | 28 ++++++
playground/terraform/README.md | 107 +++++++++++++++++++++
playground/terraform/applications/backend/main.tf | 44 +++++++++
.../terraform/applications/backend/variables.tf | 36 +++++++
playground/terraform/applications/frontend/main.tf | 44 +++++++++
.../terraform/applications/frontend/variables.tf | 36 +++++++
.../terraform/modules/artifact_registry/main.tf | 29 ++++++
.../terraform/modules/artifact_registry/output.tf | 31 ++++++
.../modules/artifact_registry/variables.tf | 35 +++++++
playground/terraform/modules/buckets/main.tf | 40 ++++++++
playground/terraform/modules/buckets/output.tf | 50 ++++++++++
playground/terraform/modules/buckets/variables.tf | 53 ++++++++++
playground/terraform/modules/vpc/main.tf | 26 +++++
playground/terraform/modules/vpc/output.tf | 27 ++++++
playground/terraform/modules/vpc/variables.tf | 41 ++++++++
playground/terraform/provider.tf | 26 +++++
sdks/go/examples/snippets/09triggers.go | 23 ++---
sdks/go/pkg/beam/core/funcx/fn.go | 16 ++-
sdks/go/pkg/beam/core/funcx/fn_test.go | 5 +
sdks/go/pkg/beam/core/funcx/sideinput.go | 25 +++++
sdks/go/pkg/beam/core/funcx/sideinput_test.go | 22 +++++
sdks/go/pkg/beam/core/graph/coder/row.go | 20 ++--
sdks/go/pkg/beam/core/graph/coder/row_test.go | 55 +++++++++--
sdks/go/pkg/beam/core/graph/window/strategy.go | 6 +-
.../core/graph/window/{ => trigger}/trigger.go | 34 ++++---
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 29 +++---
sdks/go/pkg/beam/core/runtime/harness/harness.go | 2 +-
.../pkg/beam/core/runtime/harness/sampler_hook.go | 51 ++++++++++
sdks/go/pkg/beam/util/harnessopts/sampler.go | 41 ++++++++
sdks/go/pkg/beam/util/harnessopts/sampler_test.go | 44 +++++++++
sdks/go/pkg/beam/windowing.go | 7 +-
sdks/go/test/integration/primitives/windowinto.go | 17 ++--
.../java/container/license_scripts/requirement.txt | 3 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 9 +-
.../StorageApiDynamicDestinationsTableRow.java | 49 ++++++++--
.../beam/sdk/io/gcp/testing/FakeJobService.java | 6 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 31 ++++--
.../apache_beam/runners/worker/operations.py | 1 -
sdks/python/build-requirements.txt | 1 -
sdks/python/container/base_image_requirements.txt | 3 +-
sdks/python/gen_protos.py | 18 +++-
sdks/python/scripts/generate_pydoc.sh | 3 -
sdks/python/scripts/run_pylint_2to3.sh | 23 -----
sdks/python/setup.py | 7 +-
settings.gradle.kts | 1 +
.../content/en/documentation/programming-guide.md | 8 +-
56 files changed, 1403 insertions(+), 148 deletions(-)
create mode 100644 .github/workflows/build_playground_backend.yml
create mode 100644 .github/workflows/build_playground_frontend.yml
create mode 100644 playground/backend/containers/java/app.yaml
create mode 100644 playground/backend/containers/java/build.gradle
create mode 100644 playground/backend/containers/java/settings.gradle
create mode 100755 playground/backend/env_setup.sh
create mode 100644 playground/terraform/README.md
create mode 100644 playground/terraform/applications/backend/main.tf
create mode 100644 playground/terraform/applications/backend/variables.tf
create mode 100644 playground/terraform/applications/frontend/main.tf
create mode 100644 playground/terraform/applications/frontend/variables.tf
create mode 100644 playground/terraform/modules/artifact_registry/main.tf
create mode 100644 playground/terraform/modules/artifact_registry/output.tf
create mode 100644 playground/terraform/modules/artifact_registry/variables.tf
create mode 100644 playground/terraform/modules/buckets/main.tf
create mode 100644 playground/terraform/modules/buckets/output.tf
create mode 100644 playground/terraform/modules/buckets/variables.tf
create mode 100644 playground/terraform/modules/vpc/main.tf
create mode 100644 playground/terraform/modules/vpc/output.tf
create mode 100644 playground/terraform/modules/vpc/variables.tf
create mode 100644 playground/terraform/provider.tf
rename sdks/go/pkg/beam/core/graph/window/{ => trigger}/trigger.go (87%)
create mode 100644 sdks/go/pkg/beam/core/runtime/harness/sampler_hook.go
create mode 100644 sdks/go/pkg/beam/util/harnessopts/sampler.go
create mode 100644 sdks/go/pkg/beam/util/harnessopts/sampler_test.go