(beam) branch master updated: Remove dead code. (#36943)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new e96c8dda71e Remove dead code. (#36943)
e96c8dda71e is described below

commit e96c8dda71e54e89d73b884c8ec68b6da3694d8c
Author: claudevdm <33973061+claude...@users.noreply.github.com>
AuthorDate: Mon Dec 1 12:06:54 2025 -0500

    Remove dead code. (#36943)
    
    * Remove dead code.
    
    * Lint.
---
 .../io/gcp/bigquery/StorageApiDynamicDestinationsGenericRecord.java  | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsGenericRecord.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsGenericRecord.java
index 0948876a46f..56b4be4a1a1 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsGenericRecord.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsGenericRecord.java
@@ -24,7 +24,6 @@ import com.google.protobuf.Descriptors.Descriptor;
 import com.google.protobuf.Message;
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
-import org.apache.beam.sdk.extensions.avro.schemas.utils.AvroUtils;
 import org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.DatasetService;
 import org.apache.beam.sdk.transforms.SerializableFunction;
 import org.checkerframework.checker.nullness.qual.NonNull;
@@ -63,13 +62,11 @@ class StorageApiDynamicDestinationsGenericRecord<T, 
DestinationT extends @NonNul
 
     final com.google.cloud.bigquery.storage.v1.TableSchema protoTableSchema;
     final Schema avroSchema;
-    final TableSchema bqTableSchema;
     final Descriptor descriptor;
     final @javax.annotation.Nullable Descriptor cdcDescriptor;
 
     GenericRecordConverter(DestinationT destination) throws Exception {
       avroSchema = schemaFactory.apply(getSchema(destination));
-      bqTableSchema = 
BigQueryUtils.toTableSchema(AvroUtils.toBeamSchema(avroSchema));
       protoTableSchema =
           
AvroGenericRecordToStorageApiProto.protoTableSchemaFromAvroSchema(avroSchema);
       descriptor =
@@ -112,7 +109,7 @@ class StorageApiDynamicDestinationsGenericRecord<T, 
DestinationT extends @NonNul
         return formatRecordOnFailureFunction.apply(null, element);
       } else {
         return BigQueryUtils.convertGenericRecordToTableRow(
-            toGenericRecord.apply(new AvroWriteRequest<>(element, 
avroSchema)), bqTableSchema);
+            toGenericRecord.apply(new AvroWriteRequest<>(element, 
avroSchema)));
       }
     }