This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from d5fc02479c2 [YAML] Add a basic aggregating transform to Beam Yaml.
(#29167)
add 8648e583c84 Merge pull request #29114: Support default values in
storage-api sink
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/io/gcp/bigquery/AppendClientInfo.java | 7 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 26 +-
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 6 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 7 +-
.../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 17 +-
.../StorageApiWriteRecordsInconsistent.java | 9 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 17 +-
.../bigquery/StorageApiWritesShardedRecords.java | 24 +-
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 23 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 6 +-
.../bigquery/StorageApiSinkDefaultValuesIT.java | 317 +++++++++++++++++++++
11 files changed, 432 insertions(+), 27 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiSinkDefaultValuesIT.java
