This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 41e9e04 Merge pull request #14289 from apache/aaltay-patch-1
add 6c7dff9 Revert "Merge pull request #11767: [BEAM-11648] BigQuery
Storage API sink"
add ec6035c Merge pull request #14299: Revert "[BEAM-11648] BigQuery
Storage API sink"
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 5 +-
.../cookbook/BigQueryStorageAPIStreamingIT.java | 132 ------
.../src/main/resources/beam/spotbugs-filter.xml | 3 -
.../extensions/gcp/auth/GcpCredentialFactory.java | 2 -
sdks/java/io/google-cloud-platform/build.gradle | 3 +-
.../beam/sdk/io/gcp/bigquery/BatchLoads.java | 9 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 118 +----
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 19 -
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 49 --
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 142 +-----
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 4 +-
.../beam/sdk/io/gcp/bigquery/RetryManager.java | 283 -----------
.../bigquery/StorageApiDynamicDestinations.java | 78 ---
.../StorageApiDynamicDestinationsBeamRow.java | 65 ---
.../StorageApiDynamicDestinationsTableRow.java | 71 ---
.../gcp/bigquery/StorageApiFinalizeWritesDoFn.java | 171 -------
.../bigquery/StorageApiFlushAndFinalizeDoFn.java | 207 --------
.../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 157 ------
.../bigquery/StorageApiWriteUnshardedRecords.java | 323 -------------
.../bigquery/StorageApiWritesShardedRecords.java | 524 ---------------------
.../beam/sdk/io/gcp/bigquery/TableDestination.java | 9 -
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 9 +-
.../bigquery/TwoLevelMessageConverterCache.java | 68 ---
.../sdk/io/gcp/testing/FakeDatasetService.java | 171 +------
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 2 -
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 279 ++++-------
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 52 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 4 +-
.../beam/sdk/io/gcp/bigquery/RetryManagerTest.java | 212 ---------
29 files changed, 141 insertions(+), 3030 deletions(-)
delete mode 100644
examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryStorageAPIStreamingIT.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RetryManager.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinations.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsBeamRow.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsTableRow.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFinalizeWritesDoFn.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiLoads.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TwoLevelMessageConverterCache.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/RetryManagerTest.java
