🤖 Auto format source-postgres code [skip ci]

airbytehq · Jun 21, 2023 · 52eb61d · 52eb61d
1 parent 63a14f7
commit 52eb61d
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 16 deletions.
diff --git a/airbyte-integrations/connectors/source-postgres/build.gradle b/airbyte-integrations/connectors/source-postgres/build.gradle
@@ -57,3 +57,4 @@ jsonSchema2Pojo {
     includeSetters = true
 }
 
+
diff --git a/...es/src/main/java/io/airbyte/integrations/source/postgres/ctid/AirbyteMessageWithCtid.java b/...es/src/main/java/io/airbyte/integrations/source/postgres/ctid/AirbyteMessageWithCtid.java
@@ -7,10 +7,10 @@
 import io.airbyte.protocol.models.v0.AirbyteMessage;
 
 /**
- * ctid of rows is queried as part of our sync and is used to checkpoint
- * to be able to restart failed sync from a known last point.
- * Since we never want to emit a ctid it is kept in a different field,
- * to save us an expensive JsonNode.remove() operation.
+ * ctid of rows is queried as part of our sync and is used to checkpoint to be able to restart
+ * failed sync from a known last point. Since we never want to emit a ctid it is kept in a different
+ * field, to save us an expensive JsonNode.remove() operation.
+ *
  * @param recordMessage row fields to emit
  * @param ctid ctid
  */

diff --git a/...ostgres/src/test/java/io/airbyte/integrations/source/postgres/xmin/XminCtidUtilsTest.java b/...ostgres/src/test/java/io/airbyte/integrations/source/postgres/xmin/XminCtidUtilsTest.java
@@ -1,5 +1,8 @@
-package io.airbyte.integrations.source.postgres.xmin;
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
 
+package io.airbyte.integrations.source.postgres.xmin;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -13,9 +16,9 @@
 import io.airbyte.integrations.source.postgres.internal.models.XminStatus;
 import io.airbyte.integrations.source.postgres.xmin.XminCtidUtils.StreamsCategorised;
 import io.airbyte.integrations.source.relationaldb.state.StreamStateManager;
-import io.airbyte.protocol.models.v0.AirbyteStateMessage;
 import io.airbyte.protocol.models.Field;
 import io.airbyte.protocol.models.JsonSchemaType;
+import io.airbyte.protocol.models.v0.AirbyteStateMessage;
 import io.airbyte.protocol.models.v0.AirbyteStateMessage.AirbyteStateType;
 import io.airbyte.protocol.models.v0.AirbyteStreamState;
 import io.airbyte.protocol.models.v0.CatalogHelpers;
@@ -31,20 +34,20 @@
 public class XminCtidUtilsTest {
 
   private static final ConfiguredAirbyteStream MODELS_STREAM = CatalogHelpers.toDefaultConfiguredStream(CatalogHelpers.createAirbyteStream(
-          "MODELS_STREAM_NAME",
-          "MODELS_SCHEMA",
-          Field.of("COL_ID", JsonSchemaType.INTEGER),
-          Field.of("COL_MAKE_ID", JsonSchemaType.INTEGER),
-          Field.of("COL_MODEL", JsonSchemaType.STRING))
+      "MODELS_STREAM_NAME",
+      "MODELS_SCHEMA",
+      Field.of("COL_ID", JsonSchemaType.INTEGER),
+      Field.of("COL_MAKE_ID", JsonSchemaType.INTEGER),
+      Field.of("COL_MODEL", JsonSchemaType.STRING))
       .withSupportedSyncModes(Lists.newArrayList(SyncMode.FULL_REFRESH, SyncMode.INCREMENTAL))
       .withSourceDefinedPrimaryKey(List.of(List.of("COL_ID"))));
 
   private static final ConfiguredAirbyteStream MODELS_STREAM_2 = CatalogHelpers.toDefaultConfiguredStream(CatalogHelpers.createAirbyteStream(
-          "MODELS_STREAM_NAME_2",
-          "MODELS_SCHEMA",
-          Field.of("COL_ID", JsonSchemaType.INTEGER),
-          Field.of("COL_MAKE_ID", JsonSchemaType.INTEGER),
-          Field.of("COL_MODEL", JsonSchemaType.STRING))
+      "MODELS_STREAM_NAME_2",
+      "MODELS_SCHEMA",
+      Field.of("COL_ID", JsonSchemaType.INTEGER),
+      Field.of("COL_MAKE_ID", JsonSchemaType.INTEGER),
+      Field.of("COL_MODEL", JsonSchemaType.STRING))
       .withSupportedSyncModes(Lists.newArrayList(SyncMode.FULL_REFRESH, SyncMode.INCREMENTAL))
       .withSourceDefinedPrimaryKey(List.of(List.of("COL_ID"))));