Automated Commit - Format and Process Resources Changes

airbytehq · Jul 20, 2023 · 6e82aba · 6e82aba
1 parent 45722bb
commit 6e82aba
Show file tree

Hide file tree

Showing 7 changed files with 24 additions and 3 deletions.
diff --git a/.../src/main/java/io/airbyte/integrations/base/destination/typing_deduping/RecordDiffer.java b/.../src/main/java/io/airbyte/integrations/base/destination/typing_deduping/RecordDiffer.java
@@ -203,7 +203,9 @@ private static String diffRecords(final List<JsonNode> originalExpectedRecords,
     return message;
   }
 
-  private static String diffSingleRecord(final Function<JsonNode, String> recordIdExtractor, final JsonNode expectedRecord, final JsonNode actualRecord) {
+  private static String diffSingleRecord(final Function<JsonNode, String> recordIdExtractor,
+                                         final JsonNode expectedRecord,
+                                         final JsonNode actualRecord) {
     boolean foundMismatch = false;
     String mismatchedRecordMessage = "Row had incorrect data: " + recordIdExtractor.apply(expectedRecord) + "\n";
     // Iterate through each column in the expected record and compare it to the actual record's value.

diff --git a/...in/java/io/airbyte/integrations/base/destination/typing_deduping/AirbyteProtocolType.java b/...in/java/io/airbyte/integrations/base/destination/typing_deduping/AirbyteProtocolType.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.base.destination.typing_deduping;
 
 import com.fasterxml.jackson.databind.JsonNode;

diff --git a/...eduping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/Array.java b/...eduping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/Array.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.base.destination.typing_deduping;
 
 public record Array(AirbyteType items) implements AirbyteType {

diff --git a/...duping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/Struct.java b/...duping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/Struct.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.base.destination.typing_deduping;
 
 import java.util.LinkedHashMap;

diff --git a/...eduping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/Union.java b/...eduping/src/main/java/io/airbyte/integrations/base/destination/typing_deduping/Union.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.base.destination.typing_deduping;
 
 import com.fasterxml.jackson.databind.JsonNode;

diff --git a/.../main/java/io/airbyte/integrations/base/destination/typing_deduping/UnsupportedOneOf.java b/.../main/java/io/airbyte/integrations/base/destination/typing_deduping/UnsupportedOneOf.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.base.destination.typing_deduping;
 
 import java.util.List;

diff --git a/...c/test/java/io/airbyte/integrations/base/destination/typing_deduping/AirbyteTypeTest.java b/...c/test/java/io/airbyte/integrations/base/destination/typing_deduping/AirbyteTypeTest.java
@@ -440,8 +440,7 @@ public void testChooseUnion() {
     unionToType.put(new Union(ImmutableList.of(BOOLEAN, INTEGER)), INTEGER);
 
     assertAll(
-        () -> unionToType.forEach((u, t) -> assertEquals(t, u.chooseType()))
-    );
+        () -> unionToType.forEach((u, t) -> assertEquals(t, u.chooseType())));
   }
 
   @Test