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 124e1d6a5f1 Merge pull request #25627: #25626 Use the correct
constructor when creating StreamWriter
add 9d4df48864d Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#25637)
add 8ec5673ac1c One formatter for Timestamp fields in Storage writes
(#25472)
add cf7ba6d1c59 Update mock requirement in /sdks/python (#25503)
add fabd1f6d7a6 Add ReadFrom/WriteTo Csv/Json as top-level transforms to
the Python SDK. (#25614)
add a3d82e64f31 Merge pull request #25642: #25626 Revert to old
constructor.
add d5810397e60 Fix example code on from-spark.md
add 170c4184ce1 Merge pull request #25633 from andreykot/patch-1
add 1087abeb734 Fix paginated windmill sorted list state.
add 62e9a1239bb Merge pull request #25639: Fix paginated windmill sorted
list state
add 7db76df6936 Disable triggering most IO_Direct precommit on buildSrc
and core change (#25612)
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/PrecommitJobBuilder.groovy | 18 ++-
.test-infra/jenkins/README.md | 31 +++-
.../job_PreCommit_Java_Amqp_IO_Direct.groovy | 41 -----
.../job_PreCommit_Java_Cassandra_IO_Direct.groovy | 42 ------
.../job_PreCommit_Java_Cdap_IO_Direct.groovy | 44 ------
.../job_PreCommit_Java_Clickhouse_IO_Direct.groovy | 41 -----
.../job_PreCommit_Java_Debezium_IO_Direct.groovy | 45 ------
...b_PreCommit_Java_ElasticSearch_IO_Direct.groovy | 48 ------
.../job_PreCommit_Java_HCatalog_IO_Direct.groovy | 43 ------
.../job_PreCommit_Java_Hbase_IO_Direct.groovy | 43 ------
.test-infra/jenkins/job_PreCommit_Java_IOs.groovy | 146 ++++++++++++++++++
.../job_PreCommit_Java_InfluxDb_IO_Direct.groovy | 42 ------
.../job_PreCommit_Java_Jms_IO_Direct.groovy | 41 -----
.../job_PreCommit_Java_Kudu_IO_Direct.groovy | 42 ------
.../job_PreCommit_Java_Mqtt_IO_Direct.groovy | 42 ------
.../job_PreCommit_Java_Neo4j_IO_Direct.groovy | 44 ------
.../job_PreCommit_Java_RabbitMq_IO_Direct.groovy | 42 ------
.../job_PreCommit_Java_Redis_IO_Direct.groovy | 42 ------
...job_PreCommit_Java_Singlestore_IO_Direct.groovy | 43 ------
.../job_PreCommit_Java_Snowflake_IO_Direct.groovy | 45 ------
.../job_PreCommit_Java_Solr_IO_Direct.groovy | 42 ------
.../job_PreCommit_Java_Splunk_IO_Direct.groovy | 41 -----
.../job_PreCommit_Java_Thrift_IO_Direct.groovy | 41 -----
.../job_PreCommit_Java_Tika_IO_Direct.groovy | 41 -----
CHANGES.md | 1 +
build.gradle.kts | 30 ++++
.../dataflow/worker/WindmillStateReader.java | 15 +-
.../dataflow/worker/WindmillStateReaderTest.java | 58 +++++--
sdks/go.mod | 20 +--
sdks/go.sum | 51 +++----
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 7 +-
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 39 ++++-
.../bigquery/TableRowToStorageApiProtoTest.java | 60 +++++++-
sdks/python/apache_beam/io/fileio.py | 9 +-
sdks/python/apache_beam/io/textio.py | 166 ++++++++++++++++++++-
sdks/python/apache_beam/io/textio_test.py | 33 ++++
sdks/python/scripts/generate_pydoc.sh | 4 +-
sdks/python/setup.py | 5 +-
.../www/site/content/en/get-started/from-spark.md | 9 +-
39 files changed, 615 insertions(+), 982 deletions(-)
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Amqp_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Cassandra_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Cdap_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Clickhouse_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Debezium_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_ElasticSearch_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_HCatalog_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Hbase_IO_Direct.groovy
create mode 100644 .test-infra/jenkins/job_PreCommit_Java_IOs.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_InfluxDb_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Jms_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Kudu_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Mqtt_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Neo4j_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_RabbitMq_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Redis_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Singlestore_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Snowflake_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Solr_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Splunk_IO_Direct.groovy
delete mode 100644
.test-infra/jenkins/job_PreCommit_Java_Thrift_IO_Direct.groovy
delete mode 100644 .test-infra/jenkins/job_PreCommit_Java_Tika_IO_Direct.groovy
