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 2023/06/16 05:00:26 UTC
[beam] branch nightly-refs/heads/master updated (fc74d829653 -> 644f5399dce)
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 fc74d829653 Merge pull request #27132: QuotaEvents for BigQuery
add 2bb05d3c038 Upgrade Node dependency to 14.x (#26988)
add 5723b43af0a Bump actions/stale from 6 to 8 (#27111)
add c5009375d5a Github Workflow Replacement for Jenkins Job, beam_PreCommit_Whitespace (Cron, Commit, Phrase) (#27099)
add 80f7ecba472 Bump transformers (#27109)
add edb8f2005e9 Bump transformers (#27107)
add b309d214dfc Github Workflow Replacement for Jenkins Job, beam_PreCommit_Website (Cron, Commit, Phrase) (#27098)
add 22c6e728e82 Implement Java exception sampling (#27121)
add ada507dc3b3 Implement basic mapping capabilities for YAML. (#27096)
add 857dff5005a Bump golang.org/x/sync from 0.2.0 to 0.3.0 in /sdks (#27137)
add 644f5399dce Move to a conditionVariable for messages+state stream + test. (#27060)
No new revisions were added by this update.
Summary of changes:
.github/workflows/beam_PreCommit_Website.yml | 49 ++++
.github/workflows/beam_PreCommit_Whitespace.yml | 53 +++++
.github/workflows/stale.yml | 2 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../beam/runners/prism/internal/jobservices/job.go | 45 +++-
.../prism/internal/jobservices/management.go | 83 ++++---
.../prism/internal/jobservices/management_test.go | 230 ++++++++++++++++++-
.../harness/data/PCollectionConsumerRegistry.java | 17 +-
.../beam/fn/harness/debug/ElementSample.java | 33 +--
.../beam/fn/harness/debug/OutputSampler.java | 68 +++++-
.../beam/fn/harness/debug/OutputSamplerTest.java | 79 ++++++-
.../large_language_modeling/requirements.txt | 2 +-
.../online_clustering/clustering_pipeline/setup.py | 2 +-
sdks/python/apache_beam/typehints/schemas.py | 8 +-
sdks/python/apache_beam/yaml/readme_test.py | 43 ++--
sdks/python/apache_beam/yaml/yaml_mapping.md | 196 ++++++++++++++++
sdks/python/apache_beam/yaml/yaml_mapping.py | 255 +++++++++++++++++++++
sdks/python/apache_beam/yaml/yaml_mapping_test.py | 138 +++++++++++
sdks/python/apache_beam/yaml/yaml_provider.py | 32 ++-
sdks/python/apache_beam/yaml/yaml_transform.py | 3 +-
website/Dockerfile | 2 +-
22 files changed, 1240 insertions(+), 106 deletions(-)
create mode 100644 .github/workflows/beam_PreCommit_Website.yml
create mode 100644 .github/workflows/beam_PreCommit_Whitespace.yml
copy runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.java => sdks/java/harness/src/main/java/org/apache/beam/fn/harness/debug/ElementSample.java (52%)
create mode 100644 sdks/python/apache_beam/yaml/yaml_mapping.md
create mode 100644 sdks/python/apache_beam/yaml/yaml_mapping.py
create mode 100644 sdks/python/apache_beam/yaml/yaml_mapping_test.py