This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from d391bf2b3a5 Update BigQueryIO documentation with details on how to
override the query execution project (#25400)
add 40838f76447 Support Avro GenericRecord as a valid format for
StorageWrite API on BigQueryIO (#24274)
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 20 +-
.../extensions/avro/schemas/utils/AvroUtils.java | 14 +-
.../AvroGenericRecordToStorageApiProto.java | 378 ++++++++++++++++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 50 ++-
.../beam/sdk/io/gcp/bigquery/RowWriterFactory.java | 4 +
...torageApiDynamicDestinationsGenericRecord.java} | 67 +--
.../AvroGenericRecordToStorageApiProtoTest.java | 473 +++++++++++++++++++++
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 109 +++--
8 files changed, 1036 insertions(+), 79 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroGenericRecordToStorageApiProto.java
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/{StorageApiDynamicDestinationsBeamRow.java
=> StorageApiDynamicDestinationsGenericRecord.java} (50%)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/AvroGenericRecordToStorageApiProtoTest.java