format

airbytehq · May 16, 2024 · d629ea0 · d629ea0
1 parent 157e476
commit d629ea0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresCatalogHelper.java b/...postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresCatalogHelper.java
@@ -92,7 +92,10 @@ public static AirbyteStream addCdcMetadataColumns(final AirbyteStream stream) {
   /**
    * Modifies streams that are NOT present in the publication to be full-refresh only streams. Users
    * should be able to replicate these streams, just not in incremental mode as they have no
-   * associated publication.  Previously, we also setSourceDefinedCursor(false) and setSourceDefinedPrimaryKey(List.of()) for streams that are in the catalog but not in the CDC publication, but now that full refresh streams can be resumable, we should include this information.
+   * associated publication. Previously, we also setSourceDefinedCursor(false) and
+   * setSourceDefinedPrimaryKey(List.of()) for streams that are in the catalog but not in the CDC
+   * publication, but now that full refresh streams can be resumable, we should include this
+   * information.
    */
   public static AirbyteStream setFullRefreshForNonPublicationStreams(final AirbyteStream stream,
                                                                      final Set<AirbyteStreamNameNamespacePair> publicizedTablesInCdc) {