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 f72f197 Merge pull request #15767 from ihji/BEAM-13093
add 790c32e Update readme for XVR tests
add f687ece Merge pull request #16626 from ihji/update_readme
add 368baf6 [BEAM-13537] Fix NPE in kafkatopubsub example (#16625)
add e19742e [adhoc] Test S3Options and AwsOptions for Sdk v2
add fd73461 Merge pull request #16628: [adhoc] Test S3Options and
AwsOptions for Sdk v2
add 1351030 [BEAM-13740] update java_tests.yml to remove setup-go, which
is misconfigured and blocking the build (#16608)
add e08a602 Get rid of unnessecary logs for BigQuery streaming writes in
auto-sharding mode.
add a589b10 Merge pull request #16604: [BEAM-13714] Get rid of
unnecessary logs for BigQuery streaming writes
add cf79c26 [BEAM-12976] Implement Java projection pushdown optimizer.
(#16513)
add 98b8384 Fix google3 import error
add 6a06352 Merge pull request #16635 from ihji/fix_google3_import
add 062e6ac added GitHub example references to Python multilang quickstart
add 5e528cf Merge pull request #16621: added GitHub example references to
Python multilang quickstart
No new revisions were added by this update.
Summary of changes:
.github/workflows/java_tests.yml | 20 +-
README.md | 2 +-
.../kafkatopubsub/kafka/consumer/Utils.java | 13 +-
.../options/KafkaToPubsubOptions.java | 2 +
.../graph/PCollectionOutputTagVisitor.java | 91 +++++
.../graph/ProjectionProducerVisitor.java | 6 +
.../graph/ProjectionPushdownOptimizer.java | 136 ++++++++
.../graph/ProjectionPushdownOptimizerTest.java | 366 +++++++++++++++++++++
runners/google-cloud-dataflow-java/build.gradle | 4 +
.../beam/sdk/io/aws2/options/AwsOptionsTest.java | 161 +++++++++
.../beam/sdk/io/aws2/options/S3OptionsTest.java | 119 +++++++
.../sdk/io/gcp/bigquery/BatchedStreamingWrite.java | 7 -
.../sdks/python-multi-language-pipelines.md | 32 +-
13 files changed, 924 insertions(+), 35 deletions(-)
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/PCollectionOutputTagVisitor.java
create mode 100644
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/ProjectionPushdownOptimizer.java
create mode 100644
runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/graph/ProjectionPushdownOptimizerTest.java
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/options/AwsOptionsTest.java
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/options/S3OptionsTest.java
