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 57b60e3 Merge pull request #6001 from qinyeli/master
add 277b886 Adds the BigQueryInsertError model class
add 0001afa Adds BigQueryInsertErrorCoder and tests
add fe00b20 Adds extended errors info to WriteResult
add 7782efe Makes streaming methods generic but limited to the
implemented error containers
add a3efc6e Removes ErrorContainers auxiliary class. Adds
BigQueryServicesImpl test
add 174ae48 Makes BigQueryIO.Write to be configurable to decide which
kind of errors to receive. By default disables extended errors information
(previous behavior)
add 8a6a8ea Removes unneeded coder registration
add d1b13d8 Simplifies BigQueryInsertError codification
add 07bf84b A few style improvements
new a62fa19 Merge pull request #5341: [BEAM-4257] Increases BigQuery
streaming error information
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 18 +++-
.../sdk/io/gcp/bigquery/BigQueryInsertError.java | 83 +++++++++++++++
.../io/gcp/bigquery/BigQueryInsertErrorCoder.java | 99 +++++++++++++++++
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 9 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 15 +--
.../beam/sdk/io/gcp/bigquery/ErrorContainer.java | 49 +++++++++
.../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 21 +++-
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 23 ++--
.../sdk/io/gcp/bigquery/StreamingWriteTables.java | 57 ++++++++--
.../beam/sdk/io/gcp/bigquery/WriteResult.java | 53 ++++++++-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 101 ++++++++++++++++++
.../gcp/bigquery/BigQueryInsertErrorCoderTest.java | 59 +++++++++++
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 118 +++++++++++++++++++--
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 3 +-
.../sdk/io/gcp/bigquery/FakeDatasetService.java | 16 +--
15 files changed, 669 insertions(+), 55 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertErrorCoder.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/ErrorContainer.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertErrorCoderTest.java
