This is an automated email from the ASF dual-hosted git repository.
johncasey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from b78a3e1790f fix flaky StreamingEngineClientTest (#30322)
add 6a8c27ef6fb Feature/add error handling for bqio (#30081)
No new revisions were added by this update.
Summary of changes:
.../trigger_files/beam_PostCommit_Java.json | 0
.../beam_PostCommit_Java_DataflowV1.json | 0
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.json | 0
.../beam/runners/dataflow/DataflowRunner.java | 6 +-
.../errorhandling/ErrorHandlingTestUtils.java | 9 +
.../beam/sdk/io/gcp/bigquery/AvroRowWriter.java | 10 +-
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 153 ++++++---
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 358 ++++++++++++++++++---
.../sdk/io/gcp/bigquery/BigQueryIOTranslation.java | 23 ++
.../sdk/io/gcp/bigquery/BigQueryRowWriter.java | 9 +-
.../BigQueryStorageStreamBundleSource.java | 21 +-
.../gcp/bigquery/BigQueryStorageStreamSource.java | 14 +-
.../io/gcp/bigquery/StorageApiConvertMessages.java | 43 ++-
.../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 86 ++++-
.../beam/sdk/io/gcp/bigquery/TableRowWriter.java | 10 +-
.../sdk/io/gcp/bigquery/WriteBundlesToFiles.java | 46 ++-
.../gcp/bigquery/WriteGroupedRecordsToFiles.java | 41 ++-
.../io/gcp/bigquery/BigQueryIOStorageQueryIT.java | 46 +++
.../gcp/bigquery/BigQueryIOStorageQueryTest.java | 80 +++--
.../io/gcp/bigquery/BigQueryIOStorageReadIT.java | 55 ++++
.../io/gcp/bigquery/BigQueryIOTranslationTest.java | 4 +
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 240 ++++++++++++++
22 files changed, 1084 insertions(+), 170 deletions(-)
copy
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/go-example/myfile.txt
=> .github/trigger_files/beam_PostCommit_Java.json (100%)
copy
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/go-example/myfile.txt
=> .github/trigger_files/beam_PostCommit_Java_DataflowV1.json (100%)
copy
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/go-example/myfile.txt
=> .github/trigger_files/beam_PostCommit_Python_Xlang_Gcp_Dataflow.json (100%)
