fmt

airbytehq · Feb 21, 2024 · a72aa28 · a72aa28
1 parent 559b72f
commit a72aa28
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 25 deletions.
diff --git a/...va/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftSqlGenerator.java b/...va/io/airbyte/integrations/destination/redshift/typing_deduping/RedshiftSqlGenerator.java
@@ -16,7 +16,6 @@
 import static org.jooq.impl.DSL.rowNumber;
 import static org.jooq.impl.DSL.val;
 
-import com.google.common.collect.ImmutableMap;
 import io.airbyte.cdk.integrations.destination.NamingConventionTransformer;
 import io.airbyte.cdk.integrations.destination.jdbc.typing_deduping.JdbcSqlGenerator;
 import io.airbyte.integrations.base.destination.typing_deduping.AirbyteProtocolType;
@@ -30,7 +29,6 @@
 import java.util.ArrayList;
 import java.util.LinkedHashMap;
 import java.util.List;
-import java.util.Map;
 import java.util.Optional;
 import java.util.stream.Collectors;
 import org.jooq.Condition;

diff --git a/...ntegrations/destination/redshift/typing_deduping/RedshiftSqlGeneratorIntegrationTest.java b/...ntegrations/destination/redshift/typing_deduping/RedshiftSqlGeneratorIntegrationTest.java
@@ -185,29 +185,6 @@ public void testCreateTableIncremental() throws Exception {
     final DestinationInitialState initialState = initialStates.getFirst();
     assertTrue(initialState.isFinalTablePresent());
     assertFalse(initialState.isSchemaMismatch());
-
-    // final Optional<TableDefinition> existingTable = initialStates.getFirst().get().finalTableDefinition();
-
-//    assertTrue(existingTable.isPresent());
-//    assertAll(
-//        () -> assertEquals("varchar", existingTable.get().columns().get("_airbyte_raw_id").type()),
-//        () -> assertEquals("timestamptz", existingTable.get().columns().get("_airbyte_extracted_at").type()),
-//        () -> assertEquals("super", existingTable.get().columns().get("_airbyte_meta").type()),
-//        () -> assertEquals("int8", existingTable.get().columns().get("id1").type()),
-//        () -> assertEquals("int8", existingTable.get().columns().get("id2").type()),
-//        () -> assertEquals("timestamptz", existingTable.get().columns().get("updated_at").type()),
-//        () -> assertEquals("super", existingTable.get().columns().get("struct").type()),
-//        () -> assertEquals("super", existingTable.get().columns().get("array").type()),
-//        () -> assertEquals("varchar", existingTable.get().columns().get("string").type()),
-//        () -> assertEquals("numeric", existingTable.get().columns().get("number").type()),
-//        () -> assertEquals("int8", existingTable.get().columns().get("integer").type()),
-//        () -> assertEquals("bool", existingTable.get().columns().get("boolean").type()),
-//        () -> assertEquals("timestamptz", existingTable.get().columns().get("timestamp_with_timezone").type()),
-//        () -> assertEquals("timestamp", existingTable.get().columns().get("timestamp_without_timezone").type()),
-//        () -> assertEquals("timetz", existingTable.get().columns().get("time_with_timezone").type()),
-//        () -> assertEquals("time", existingTable.get().columns().get("time_without_timezone").type()),
-//        () -> assertEquals("date", existingTable.get().columns().get("date").type()),
-//        () -> assertEquals("super", existingTable.get().columns().get("unknown").type()));
     // TODO assert on table clustering, etc.
   }