This is an automated email from the ASF dual-hosted git repository.
ahmedabualsaud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from df106091290 Update names.py with container image tag (#32160)
add 74668038c02 Support withFormatRecordOnFailureFunction() for BigQuery
STORAGE_WRITE_API and STORAGE_API_AT_LEAST_ONCE methods (#31659)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 18 +-
.../sdk/io/gcp/bigquery/SplittingIterable.java | 18 +-
.../io/gcp/bigquery/StorageApiConvertMessages.java | 8 +-
.../bigquery/StorageApiDynamicDestinations.java | 2 +-
.../StorageApiDynamicDestinationsBeamRow.java | 16 +-
...StorageApiDynamicDestinationsGenericRecord.java | 20 +-
.../StorageApiDynamicDestinationsProto.java | 31 +-
.../StorageApiDynamicDestinationsTableRow.java | 16 +-
.../io/gcp/bigquery/StorageApiWritePayload.java | 22 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 65 ++--
.../bigquery/StorageApiWritesShardedRecords.java | 26 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 336 ++++++++++++++++++++-
13 files changed, 522 insertions(+), 57 deletions(-)
