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 7c07f7ff453 Create CsvIOParse scaffold (#31878)
add 86ea7806eca Remove auth@1 in tests running on self hosted runner
(#31881)
add 36f16314052 [CsvIO] Create scaffold CsvIOParseKV class (#31880)
add faff55c2882 Fix auth for clean up actions (#31888)
add 0b61035f36f Increase retry backoff for Storage API batch to survive
AppendRows quota refill (#31837)
add 408f67cfc83 Create CsvIOParseHelpers::mapFieldPositions method (#31889)
add 3e7614a50e5 Bump braces from 3.0.2 to 3.0.3 in /scripts/ci/pr-bot
(#31886)
add ea761115998 [CsvIO] Create CsvIOStringToCsvRecord Class (#31857)
No new revisions were added by this update.
Summary of changes:
.github/workflows/IO_Iceberg_Integration_Tests.yml | 6 -
.github/workflows/IO_Iceberg_Performance_Tests.yml | 6 -
.github/workflows/IO_Iceberg_Unit_Tests.yml | 6 -
.github/workflows/beam_CancelStaleDataflowJobs.yml | 6 -
.github/workflows/beam_CleanUpGCPResources.yml | 9 +-
.../workflows/beam_CleanUpPrebuiltSDKImages.yml | 6 -
.../beam_PerformanceTests_AvroIOIT_HDFS.yml | 6 -
.github/workflows/beam_PerformanceTests_Cdap.yml | 6 -
...m_PerformanceTests_Compressed_TextIOIT_HDFS.yml | 6 -
.../beam_PerformanceTests_HadoopFormat.yml | 6 -
.github/workflows/beam_PerformanceTests_JDBC.yml | 6 -
.../workflows/beam_PerformanceTests_Kafka_IO.yml | 6 -
...am_PerformanceTests_ManyFiles_TextIOIT_HDFS.yml | 6 -
.../beam_PerformanceTests_MongoDBIO_IT.yml | 6 -
.../beam_PerformanceTests_ParquetIOIT_HDFS.yml | 6 -
.../beam_PerformanceTests_SingleStoreIO.yml | 6 -
.../beam_PerformanceTests_SparkReceiver_IO.yml | 6 -
.../beam_PerformanceTests_TFRecordIOIT_HDFS.yml | 6 -
.../beam_PerformanceTests_XmlIOIT_HDFS.yml | 6 -
.../beam_PerformanceTests_xlang_KafkaIO_Python.yml | 6 -
.../beam_PostCommit_Java_InfluxDbIO_IT.yml | 6 -
.../beam_PostCommit_Java_SingleStoreIO_IT.yml | 6 -
.../workflows/beam_StressTests_Java_KafkaIO.yml | 6 -
.github/workflows/build_runner_image.yml | 6 -
.test-infra/tools/stale_bq_datasets_cleaner.sh | 4 +-
CHANGES.md | 3 +-
scripts/ci/pr-bot/package-lock.json | 28 ++--
.../apache/beam/sdk/io/csv/CsvIOParseHelpers.java | 34 ++++-
.../org/apache/beam/sdk/io/csv/CsvIOParseKV.java | 31 ++---
.../beam/sdk/io/csv/CsvIOStringToCsvRecord.java | 61 +++++++++
.../beam/sdk/io/csv/CsvIOParseHelpersTest.java | 88 +++++++++++++
...onfigurationTest.java => CsvIOParseKVTest.java} | 6 +-
.../sdk/io/csv/CsvIOStringToCsvRecordTest.java | 143 +++++++++++++++++++++
.../bigquery/StorageApiWriteUnshardedRecords.java | 2 +-
34 files changed, 359 insertions(+), 188 deletions(-)
copy
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefix.java
=> sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseKV.java
(59%)
create mode 100644
sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOStringToCsvRecord.java
copy
sdks/java/io/csv/src/test/java/org/apache/beam/sdk/io/csv/{CsvIOParseConfigurationTest.java
=> CsvIOParseKVTest.java} (83%)
create mode 100644
sdks/java/io/csv/src/test/java/org/apache/beam/sdk/io/csv/CsvIOStringToCsvRecordTest.java
