[BigQueryIO] fetch updated schema for newly created Storage API stream writers (#33231)
* add dynamic dest test * fix and add some tests * add to changes.md * fix whitespace * trigger postcommits * address comments
显示
- .github/trigger_files/beam_PostCommit_Java_DataflowV2.json 1 个添加, 1 个删除.github/trigger_files/beam_PostCommit_Java_DataflowV2.json
- CHANGES.md 1 个添加, 0 个删除CHANGES.md
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java 1 个添加, 1 个删除...org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java 11 个添加, 2 个删除...apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java 11 个添加, 9 个删除.../sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java 22 个添加, 0 个删除...m/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java 2 个添加, 2 个删除...rg/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiSinkSchemaUpdateIT.java 187 个添加, 19 个删除...eam/sdk/io/gcp/bigquery/StorageApiSinkSchemaUpdateIT.java
加载中