You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2025/12/01 17:07:00 UTC
(beam) branch master updated: Remove dead code. (#36943)
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 <33...@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)));
}
}