Merge pull request #38292 from apache/fix-hadoop-format

Fix PerformanceTests HadoopFormat job

Author: Amar3tto

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslation.java

@@ -73,7 +73,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-@SuppressWarnings({"rawtypes", "nullness"})
+@SuppressWarnings({"rawtypes", "nullness", "AutoValueSubclassLeaked"})
 public class BigQueryIOTranslation {
 
   private static final Logger LOG = LoggerFactory.getLogger(BigQueryIOTranslation.class);
@@ -217,7 +217,7 @@ public TypedRead<?> fromConfigRow(Row configRow, PipelineOptions options) {
           (updateCompatibilityBeamVersion != null) ? updateCompatibilityBeamVersion : "2.53.0";
 
       try {
-        BigQueryIO.TypedRead.Builder builder = BigQueryIO.TypedRead.builder();
+        BigQueryIO.TypedRead.Builder builder = new AutoValue_BigQueryIO_TypedRead.Builder<>();
 
         String jsonTableRef = configRow.getString("json_table_ref");
         if (jsonTableRef != null) {
@@ -378,9 +378,7 @@ public static class ReadRegistrar implements TransformPayloadTranslatorRegistrar
     public Map<? extends Class<? extends PTransform>, ? extends TransformPayloadTranslator>
         getTransformPayloadTranslators() {
       return ImmutableMap.<Class<? extends PTransform>, TransformPayloadTranslator>builder()
-          .put(
-              BigQueryIO.read(BigQueryIO.TableRowParser.INSTANCE).getClass(),
-              new BigQueryIOReadTranslator())
+          .put(AutoValue_BigQueryIO_TypedRead.class, new BigQueryIOReadTranslator())
           .build();
     }
   }
@@ -617,7 +615,7 @@ public Write<?> fromConfigRow(Row configRow, PipelineOptions options) {
           (updateCompatibilityBeamVersion != null) ? updateCompatibilityBeamVersion : "2.53.0";
 
       try {
-        BigQueryIO.Write.Builder builder = BigQueryIO.Write.builder();
+        BigQueryIO.Write.Builder builder = new AutoValue_BigQueryIO_Write.Builder<>();
 
         String jsonTableRef = configRow.getString("json_table_ref");
         if (jsonTableRef != null) {
@@ -930,7 +928,7 @@ public static class WriteRegistrar implements TransformPayloadTranslatorRegistra
     public Map<? extends Class<? extends PTransform>, ? extends TransformPayloadTranslator>
         getTransformPayloadTranslators() {
       return ImmutableMap.<Class<? extends PTransform>, TransformPayloadTranslator>builder()
-          .put(BigQueryIO.write().getClass(), new BigQueryIOWriteTranslator())
+          .put(AutoValue_BigQueryIO_Write.class, new BigQueryIOWriteTranslator())
           .build();
     }
   }