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 0b47f1b Merge pull request #15835: [BEAM-11205] Google Libraries BOM
24.0.0 and associated deps
add fafe9d1 Merge pull request #15810: [BEAM-2791] Support low-latency
StorageApi sink with no exactly-once guarantees
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 22 ++-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 7 +
.../sdk/io/gcp/bigquery/SplittingIterable.java | 69 +++++++
.../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 32 ++-
.../StorageApiWriteRecordsInconsistent.java | 75 +++++++
.../bigquery/StorageApiWriteUnshardedRecords.java | 220 ++++++++++++++-------
.../bigquery/StorageApiWritesShardedRecords.java | 49 -----
.../sdk/io/gcp/testing/FakeDatasetService.java | 38 +++-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 41 +++-
9 files changed, 413 insertions(+), 140 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/SplittingIterable.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteRecordsInconsistent.java
