From 984673d3a1d183ecab62ab02e58bd320c7161f58 Mon Sep 17 00:00:00 2001 From: Ahmed Abualsaud Date: Wed, 18 Dec 2024 11:35:30 -0500 Subject: [PATCH] add comment --- .../providers/BigQueryFileLoadsSchemaTransformProvider.java | 1 + 1 file changed, 1 insertion(+) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryFileLoadsSchemaTransformProvider.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryFileLoadsSchemaTransformProvider.java index 0e52104131a4..1c5f2ef1c7d7 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryFileLoadsSchemaTransformProvider.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryFileLoadsSchemaTransformProvider.java @@ -108,6 +108,7 @@ BigQueryIO.Write toWrite(Schema schema, PipelineOptions options) { .withCustomGcsTempLocation( ValueProvider.StaticValueProvider.of(options.getTempLocation())) .withWriteDisposition(WriteDisposition.WRITE_APPEND) + // Use Avro format for better performance. Don't change this unless it's for a good reason. .withAvroFormatFunction(dynamicDestinations.getAvroFilterFormatFunction(false)); if (!Strings.isNullOrEmpty(configuration.getCreateDisposition())) {