Merge branch 'master' into edgao/dv2/release

airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryStagingConsumerFactory.java

@@ -47,15 +47,15 @@ public class BigQueryStagingConsumerFactory {
   private static final Logger LOGGER = LoggerFactory.getLogger(BigQueryStagingConsumerFactory.class);
 
   public AirbyteMessageConsumer create(final JsonNode config,
-      final ConfiguredAirbyteCatalog catalog,
-      final Consumer<AirbyteMessage> outputRecordCollector,
-      final BigQueryStagingOperations bigQueryGcsOperations,
-      final BufferCreateFunction onCreateBuffer,
-      final Function<JsonNode, BigQueryRecordFormatter> recordFormatterCreator,
-      final Function<String, String> tmpTableNameTransformer,
-      final TyperDeduper typerDeduper,
-      final ParsedCatalog parsedCatalog,
-      final String defaultNamespace)
+                                       final ConfiguredAirbyteCatalog catalog,
+                                       final Consumer<AirbyteMessage> outputRecordCollector,
+                                       final BigQueryStagingOperations bigQueryGcsOperations,
+                                       final BufferCreateFunction onCreateBuffer,
+                                       final Function<JsonNode, BigQueryRecordFormatter> recordFormatterCreator,
+                                       final Function<String, String> tmpTableNameTransformer,
+                                       final TyperDeduper typerDeduper,
+                                       final ParsedCatalog parsedCatalog,
+                                       final String defaultNamespace)
       throws Exception {
     final Map<AirbyteStreamNameNamespacePair, BigQueryWriteConfig> writeConfigs = createWriteConfigs(
         config,

airbyte-integrations/connectors/destination-redshift/src/main/java/io/airbyte/integrations/destination/redshift/RedshiftStagingS3Destination.java

@@ -145,7 +145,10 @@ public AirbyteMessageConsumer getConsumer(final JsonNode config,
   }
 
   @Override
-  public SerializedAirbyteMessageConsumer getSerializedMessageConsumer(final JsonNode config, final ConfiguredAirbyteCatalog catalog, final Consumer<AirbyteMessage> outputRecordCollector) throws Exception {
+  public SerializedAirbyteMessageConsumer getSerializedMessageConsumer(JsonNode config,
+                                                                       ConfiguredAirbyteCatalog catalog,
+                                                                       Consumer<AirbyteMessage> outputRecordCollector)
+      throws Exception {
     final EncryptionConfig encryptionConfig =
         config.has(UPLOADING_METHOD) ? EncryptionConfig.fromJson(config.get(UPLOADING_METHOD).get(JdbcUtils.ENCRYPTION_KEY)) : new NoEncryption();
     final JsonNode s3Options = findS3Options(config);

airbyte-integrations/connectors/destination-snowflake/src/main/java/io/airbyte/integrations/destination/snowflake/SnowflakeSqlOperations.java

@@ -48,12 +48,12 @@ public void createSchemaIfNotExists(final JdbcDatabase database, final String sc
   public String createTableQuery(final JdbcDatabase database, final String schemaName, final String tableName) {
     return String.format(
         """
-            CREATE TABLE IF NOT EXISTS "%s"."%s" (
-              "%s" VARCHAR PRIMARY KEY,
-              "%s" TIMESTAMP WITH TIME ZONE DEFAULT current_timestamp(),
-              "%s" TIMESTAMP WITH TIME ZONE DEFAULT NULL,
-              "%s" VARIANT
-            ) data_retention_time_in_days = 0;""",
+        CREATE TABLE IF NOT EXISTS "%s"."%s" (
+          "%s" VARCHAR PRIMARY KEY,
+          "%s" TIMESTAMP WITH TIME ZONE DEFAULT current_timestamp(),
+          "%s" TIMESTAMP WITH TIME ZONE DEFAULT NULL,
+          "%s" VARIANT
+        ) data_retention_time_in_days = 0;""",
         schemaName,
         tableName,
         JavaBaseConstants.COLUMN_NAME_AB_RAW_ID,
@@ -100,7 +100,8 @@ public void insertRecordsInternal(final JdbcDatabase database,
     // SqlOperationsUtils.insertRawRecordsInSingleQuery to support a different column order.
     insertQuery = String.format(
         "INSERT INTO \"%s\".\"%s\" (\"%s\", \"%s\", \"%s\") SELECT column1, parse_json(column2), column3 FROM VALUES\n",
-        schemaName, tableName, JavaBaseConstants.COLUMN_NAME_AB_RAW_ID, JavaBaseConstants.COLUMN_NAME_DATA, JavaBaseConstants.COLUMN_NAME_AB_EXTRACTED_AT);
+        schemaName, tableName, JavaBaseConstants.COLUMN_NAME_AB_RAW_ID, JavaBaseConstants.COLUMN_NAME_DATA,
+        JavaBaseConstants.COLUMN_NAME_AB_EXTRACTED_AT);
     final String recordQuery = "(?, ?, ?),\n";
     SqlOperationsUtils.insertRawRecordsInSingleQuery(insertQuery, recordQuery, database, records);
   }