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 2022/07/12 05:12:59 UTC
[beam] branch nightly-refs/heads/master updated (262f2b7f91a -> a8775f0a4ac)
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 262f2b7f91a Parallelizable DataFrame/Series mean (#22174)
add 3d8db78984e Split checkStyle from precommit into spotless job (#22203)
add abc8099d71b Allow one to bound the size of output shards when writing to files. (#22130)
add 821c07f54d6 Bump moment from 2.29.2 to 2.29.4 in /sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel (#22200)
add da84804bc01 Allow BigQuery TableIds to have space in between (#22167)
add 6e16941d69f Use async as a suffix rather than a prefix for asynchronous variants. (#22134)
add eb071fa1036 Override log levels after log handler is created (#22191)
add ca7b3b5e91c Remove deprecated unused option in seed job script (#22223)
add 983e5c0c372 Better error for external BigQuery tables. (#22178)
add a8775f0a4ac Try to fix playground workflow (#22226)
No new revisions were added by this update.
Summary of changes:
.github/workflows/playground_deploy_examples.yml | 2 +-
.../jenkins/committers_list_generator/main.py | 1 -
...tCommit_Java_Examples_Dataflow_V2_Java11.groovy | 1 +
...tCommit_Java_Examples_Dataflow_V2_Java17.groovy | 1 +
.test-infra/jenkins/job_PreCommit_Java.groovy | 6 +-
.../job_PreCommit_Java_AWS2_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_AWS_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_Debezium_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_Examples_Dataflow.groovy | 3 +-
..._PreCommit_Java_Examples_Dataflow_Java11.groovy | 2 +
.../job_PreCommit_Java_GCP_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_JDBC_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_Kafka_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_Kinesis_IO_Direct.groovy | 3 +-
.../job_PreCommit_Java_Neo4j_IO_Direct.groovy | 3 +-
.test-infra/jenkins/job_PreCommit_SQL.groovy | 7 +--
.../jenkins/job_PreCommit_SQL_Java11.groovy | 4 +-
.../jenkins/job_PreCommit_SQL_Java17.groovy | 4 +-
.test-infra/jenkins/job_PreCommit_Spotless.groovy | 15 ++++-
..._Precommit_Java_Examples_Dataflow_Java17.groovy | 2 +
.test-infra/jenkins/job_sonarqube_report.groovy | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 6 ++
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 18 +++++-
sdks/python/apache_beam/io/filebasedsink.py | 39 ++++++++++++-
sdks/python/apache_beam/io/gcp/bigquery.py | 68 +++++++++++++---------
.../apache_beam/io/gcp/bigquery_read_internal.py | 47 +++++++++------
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 7 ++-
.../apache_beam/io/gcp/bigquery_tools_test.py | 11 ++++
sdks/python/apache_beam/io/iobase.py | 12 +++-
sdks/python/apache_beam/io/textio.py | 28 ++++++++-
sdks/python/apache_beam/io/textio_test.py | 42 +++++++++++++
.../apache-beam-jupyterlab-sidepanel/yarn.lock | 6 +-
.../apache_beam/runners/worker/sdk_worker_main.py | 17 +++---
.../runners/worker/sdk_worker_main_test.py | 25 ++++++++
.../src/apache_beam/examples/wordcount_sql.ts | 2 +-
.../src/apache_beam/examples/wordcount_textio.ts | 2 +-
.../src/apache_beam/internal/pipeline.ts | 4 +-
sdks/typescript/src/apache_beam/io/avroio.ts | 2 +-
sdks/typescript/src/apache_beam/io/parquetio.ts | 4 +-
sdks/typescript/src/apache_beam/io/pubsub.ts | 4 +-
sdks/typescript/src/apache_beam/io/textio.ts | 12 ++--
sdks/typescript/src/apache_beam/pvalue.ts | 14 ++---
.../src/apache_beam/transforms/external.ts | 2 +-
sdks/typescript/src/apache_beam/transforms/sql.ts | 2 +-
.../src/apache_beam/transforms/transform.ts | 10 ++--
sdks/typescript/test/docs/programming_guide.ts | 2 +-
sdks/typescript/test/io_test.ts | 32 +++++-----
.../content/en/documentation/programming-guide.md | 4 +-
48 files changed, 354 insertions(+), 142 deletions(-)