Merge pull request #29785: Fix typos

apache · Dec 21, 2023 · 78e231a · 78e231a
2 parents 7e4dc66 + 6499c65
commit 78e231a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/...oud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslation.java b/...oud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslation.java
@@ -353,7 +353,7 @@ static class BigQueryIOWriteTranslator implements TransformPayloadTranslator<Wri
             .addNullableBooleanField("propagate_successful_storage_api_writes")
             .addNullableInt32Field("max_files_per_partition")
             .addNullableInt64Field("max_bytes_per_partition")
-            .addNullableLogicalTypeField("triggerring_frequency", new NanosDuration())
+            .addNullableLogicalTypeField("triggering_frequency", new NanosDuration())
             .addNullableByteArrayField("method")
             .addNullableStringField("load_job_project_id")
             .addNullableByteArrayField("failed_insert_retry_policy")
@@ -477,7 +477,7 @@ public Row toConfigRow(Write<?> transform) {
       fieldValues.put("max_bytes_per_partition", transform.getMaxBytesPerPartition());
       if (transform.getTriggeringFrequency() != null) {
         fieldValues.put(
-            "triggerring_frequency",
+            "triggering_frequency",
             Duration.ofMillis(transform.getTriggeringFrequency().getMillis()));
       }
       if (transform.getMethod() != null) {
@@ -695,11 +695,11 @@ public Write<?> fromConfigRow(Row configRow) {
         if (maxBytesPerPartition != null) {
           builder = builder.setMaxBytesPerPartition(maxBytesPerPartition);
         }
-        Duration triggerringFrequency = configRow.getValue("triggerring_frequency");
-        if (triggerringFrequency != null) {
+        Duration triggeringFrequency = configRow.getValue("triggering_frequency");
+        if (triggeringFrequency != null) {
           builder =
               builder.setTriggeringFrequency(
-                  org.joda.time.Duration.millis(triggerringFrequency.toMillis()));
+                  org.joda.time.Duration.millis(triggeringFrequency.toMillis()));
         }
         byte[] methodBytes = configRow.getBytes("method");
         if (methodBytes != null) {

diff --git a/...platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslationTest.java b/...platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslationTest.java
@@ -100,7 +100,7 @@ public class BigQueryIOTranslationTest {
         "getPropagateSuccessfulStorageApiWrites", "propagate_successful_storage_api_writes");
     WRITE_TRANSFORM_SCHEMA_MAPPING.put("getMaxFilesPerPartition", "max_files_per_partition");
     WRITE_TRANSFORM_SCHEMA_MAPPING.put("getMaxBytesPerPartition", "max_bytes_per_partition");
-    WRITE_TRANSFORM_SCHEMA_MAPPING.put("getTriggeringFrequency", "triggerring_frequency");
+    WRITE_TRANSFORM_SCHEMA_MAPPING.put("getTriggeringFrequency", "triggering_frequency");
     WRITE_TRANSFORM_SCHEMA_MAPPING.put("getMethod", "method");
     WRITE_TRANSFORM_SCHEMA_MAPPING.put("getLoadJobProjectId", "load_job_project_id");
     WRITE_TRANSFORM_SCHEMA_MAPPING.put("getFailedInsertRetryPolicy", "failed_insert_retry_policy");