run gradlew format (#14721)

airbytehq · Jul 14, 2022 · 8bbe993 · 8bbe993
1 parent 5a7b3a5
commit 8bbe993
Show file tree

Hide file tree

Showing 56 changed files with 1,218 additions and 2,526 deletions.
diff --git a/...ava/io/airbyte/integrations/destination/cassandra/CassandraDestinationAcceptanceTest.java b/...ava/io/airbyte/integrations/destination/cassandra/CassandraDestinationAcceptanceTest.java
@@ -12,8 +12,6 @@
 import java.util.List;
 import java.util.stream.Collectors;
 import org.junit.jupiter.api.BeforeAll;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 public class CassandraDestinationAcceptanceTest extends DestinationAcceptanceTest {
 

diff --git a/...e/src/main/java/io/airbyte/integrations/destination/clickhouse/ClickhouseDestination.java b/...e/src/main/java/io/airbyte/integrations/destination/clickhouse/ClickhouseDestination.java
@@ -17,7 +17,6 @@
 import io.airbyte.integrations.destination.jdbc.AbstractJdbcDestination;
 import io.airbyte.protocol.models.AirbyteConnectionStatus;
 import io.airbyte.protocol.models.AirbyteConnectionStatus.Status;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import javax.sql.DataSource;

diff --git a/...c/test/java/io/airbyte/integrations/destination/clickhouse/ClickhouseDestinationTest.java b/...c/test/java/io/airbyte/integrations/destination/clickhouse/ClickhouseDestinationTest.java
@@ -27,7 +27,6 @@
 import io.airbyte.protocol.models.JsonSchemaType;
 import java.time.Instant;
 import java.util.Comparator;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;

diff --git a/...t-integration/java/io/airbyte/integrations/destination/mysql/MySqlTestDataComparator.java b/...t-integration/java/io/airbyte/integrations/destination/mysql/MySqlTestDataComparator.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2021 Airbyte, Inc., all rights reserved.
+ * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
  */
 
 package io.airbyte.integrations.destination.mysql;

diff --git a/.../main/java/io/airbyte/integrations/destination/redshift/RedshiftStagingS3Destination.java b/.../main/java/io/airbyte/integrations/destination/redshift/RedshiftStagingS3Destination.java
@@ -59,15 +59,16 @@ private boolean isEphemeralKeysAndPurgingStagingData(JsonNode config, Encryption
   @Override
   public AirbyteConnectionStatus check(final JsonNode config) {
     final S3DestinationConfig s3Config = getS3DestinationConfig(findS3Options(config));
-    final EncryptionConfig encryptionConfig = config.has("uploading_method") ?
-        EncryptionConfig.fromJson(config.get("uploading_method").get("encryption")) : new NoEncryption();
+    final EncryptionConfig encryptionConfig =
+        config.has("uploading_method") ? EncryptionConfig.fromJson(config.get("uploading_method").get("encryption")) : new NoEncryption();
     if (isEphemeralKeysAndPurgingStagingData(config, encryptionConfig)) {
       return new AirbyteConnectionStatus()
           .withStatus(Status.FAILED)
           .withMessage(
               "You cannot use ephemeral keys and disable purging your staging data. This would produce S3 objects that you cannot decrypt.");
     }
-    S3Destination.attemptS3WriteAndDelete(new S3StorageOperations(new RedshiftSQLNameTransformer(), s3Config.getS3Client(), s3Config), s3Config, s3Config.getBucketPath());
+    S3Destination.attemptS3WriteAndDelete(new S3StorageOperations(new RedshiftSQLNameTransformer(), s3Config.getS3Client(), s3Config), s3Config,
+        s3Config.getBucketPath());
 
     final NamingConventionTransformer nameTransformer = getNamingResolver();
     final RedshiftS3StagingSqlOperations redshiftS3StagingSqlOperations =
@@ -124,8 +125,8 @@ public JsonNode toJdbcConfig(final JsonNode config) {
   public AirbyteMessageConsumer getConsumer(final JsonNode config,
                                             final ConfiguredAirbyteCatalog catalog,
                                             final Consumer<AirbyteMessage> outputRecordCollector) {
-    final EncryptionConfig encryptionConfig = config.has("uploading_method") ?
-        EncryptionConfig.fromJson(config.get("uploading_method").get("encryption")) : new NoEncryption();
+    final EncryptionConfig encryptionConfig =
+        config.has("uploading_method") ? EncryptionConfig.fromJson(config.get("uploading_method").get("encryption")) : new NoEncryption();
     final JsonNode s3Options = findS3Options(config);
     final S3DestinationConfig s3Config = getS3DestinationConfig(s3Options);
     return new StagingConsumerFactory().create(

diff --git a/...io/airbyte/integrations/destination/redshift/RedshiftInsertDestinationAcceptanceTest.java b/...io/airbyte/integrations/destination/redshift/RedshiftInsertDestinationAcceptanceTest.java
@@ -78,7 +78,6 @@ void setup() {
             .withDestinationSyncMode(DestinationSyncMode.APPEND)));
   }
 
-
   @Test
   void testIfSuperTmpTableWasCreatedAfterVarcharTmpTable() throws Exception {
     setup();

diff --git a/...ift/src/test/java/io/airbyte/integrations/destination/redshift/util/RedshiftUtilTest.java b/...ift/src/test/java/io/airbyte/integrations/destination/redshift/util/RedshiftUtilTest.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright (c) 2022 Airbyte, Inc., all rights reserved.
+ */
+
 package io.airbyte.integrations.destination.redshift.util;
 
 import static io.airbyte.integrations.destination.redshift.constants.RedshiftDestinationConstants.UPLOADING_METHOD;
@@ -64,4 +68,5 @@ public void testAllS3RequiredAreNotNullOrEmptyThenReturnFalse() {
 
     assertFalse(RedshiftUtil.anyOfS3FieldsAreNullOrEmpty(jsonNode));
   }
-}
+
+}
diff --git a/...tination-s3/src/main/java/io/airbyte/integrations/destination/s3/S3DestinationConfig.java b/...tination-s3/src/main/java/io/airbyte/integrations/destination/s3/S3DestinationConfig.java
@@ -10,10 +10,10 @@
 import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
 import com.fasterxml.jackson.databind.JsonNode;
+import io.airbyte.integrations.destination.s3.credential.S3AWSDefaultProfileCredentialConfig;
 import io.airbyte.integrations.destination.s3.credential.S3AccessKeyCredentialConfig;
 import io.airbyte.integrations.destination.s3.credential.S3CredentialConfig;
 import io.airbyte.integrations.destination.s3.credential.S3CredentialType;
-import io.airbyte.integrations.destination.s3.credential.S3AWSDefaultProfileCredentialConfig;
 import java.util.Objects;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

diff --git a/...integrations/io/airbyte/integration_tests/sources/Db2SourceCertificateAcceptanceTest.java b/...integrations/io/airbyte/integration_tests/sources/Db2SourceCertificateAcceptanceTest.java
@@ -15,7 +15,6 @@
 import io.airbyte.integrations.source.db2.Db2Source;
 import io.airbyte.integrations.standardtest.source.SourceAcceptanceTest;
 import io.airbyte.integrations.standardtest.source.TestDestinationEnv;
-import io.airbyte.integrations.util.HostPortResolver;
 import io.airbyte.protocol.models.CatalogHelpers;
 import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
 import io.airbyte.protocol.models.ConfiguredAirbyteStream;

diff --git a/...onnectors/source-file/integration_tests/sample_files/formats/yaml/configured_catalog.json b/...onnectors/source-file/integration_tests/sample_files/formats/yaml/configured_catalog.json
@@ -10,14 +10,14 @@
             "$schema": "http://json-schema.org/schema#",
             "type": "object",
             "properties": {
-              "name": {"type":  "string"},
-              "sourceDefinitionId": {"type":  "string"},
-              "dockerRepository": {"type":  "string"},
-              "dockerImageTag": {"type":  "string"},
-              "documentationUrl": {"type":  "string"},
-              "icon": {"type":  "string"},
-              "sourceType": {"type":  "string"},
-              "releaseStage": {"type":  "string"}
+              "name": { "type": "string" },
+              "sourceDefinitionId": { "type": "string" },
+              "dockerRepository": { "type": "string" },
+              "dockerImageTag": { "type": "string" },
+              "documentationUrl": { "type": "string" },
+              "icon": { "type": "string" },
+              "sourceType": { "type": "string" },
+              "releaseStage": { "type": "string" }
             }
           }
         }

diff --git a/...integrations/connectors/source-file/integration_tests/sample_files/formats/yaml/demo.yaml b/...integrations/connectors/source-file/integration_tests/sample_files/formats/yaml/demo.yaml
@@ -20,4 +20,4 @@
   documentationUrl: https://docs.airbyte.io/integrations/sources/file
   icon: file.svg
   sourceType: file
-  releaseStage: alpha
+  releaseStage: alpha
diff --git a/...tegrations/connectors/source-google-analytics-data-api/integration_tests/input_state.json b/...tegrations/connectors/source-google-analytics-data-api/integration_tests/input_state.json
@@ -1 +1 @@
-{"crash_report":{"date":"20220429"}}
+{ "crash_report": { "date": "20220429" } }
diff --git a/...ns/connectors/source-google-analytics-data-api/source_google_analytics_data_api/spec.json b/...ns/connectors/source-google-analytics-data-api/source_google_analytics_data_api/spec.json
@@ -5,8 +5,12 @@
     "title": "Google Analytics Data API Spec",
     "type": "object",
     "required": [
-      "property_id", "json_credentials", "report_name",
-      "dimensions", "metrics", "date_ranges_start_date",
+      "property_id",
+      "json_credentials",
+      "report_name",
+      "dimensions",
+      "metrics",
+      "date_ranges_start_date",
       "date_ranges_end_date"
     ],
     "additionalProperties": false,

diff --git a/airbyte-integrations/connectors/source-intercom/integration_tests/sample_state.json b/airbyte-integrations/connectors/source-intercom/integration_tests/sample_state.json
@@ -23,4 +23,4 @@
   "segments": {
     "updated_at": 1626086649
   }
-}
+}
diff --git a/...e-integrations/connectors/source-intercom/source_intercom/schemas/conversation_parts.json b/...e-integrations/connectors/source-intercom/source_intercom/schemas/conversation_parts.json
@@ -6,12 +6,12 @@
       "oneOf": [
         {
           "type": "object",
-            "properties": {
-              "type": {
-                "type": ["null", "string"]
-              },
-              "id": {
-                "type": ["null", "string"]
+          "properties": {
+            "type": {
+              "type": ["null", "string"]
+            },
+            "id": {
+              "type": ["null", "string"]
             }
           }
         },

diff --git a/airbyte-integrations/connectors/source-kyriba/integration_tests/abnormal_state.json b/airbyte-integrations/connectors/source-kyriba/integration_tests/abnormal_state.json
@@ -1 +1 @@
-{"cash_flows": {"updateDateTime": "9999-05-04T18:31:18Z"}}
+{ "cash_flows": { "updateDateTime": "9999-05-04T18:31:18Z" } }
diff --git a/airbyte-integrations/connectors/source-kyriba/integration_tests/configured_catalog.json b/airbyte-integrations/connectors/source-kyriba/integration_tests/configured_catalog.json
@@ -1,74 +1,74 @@
 {
-    "streams": [
-        {
-            "stream": {
-                "name": "bank_balances_intraday",
-                "json_schema": {
-                    "$schema": "http://json-schema.org/draft-04/schema"
-                },
-                "supported_sync_modes": ["full_refresh"]
-            },
-            "sync_mode": "full_refresh",
-            "destination_sync_mode": "overwrite"
+  "streams": [
+    {
+      "stream": {
+        "name": "bank_balances_intraday",
+        "json_schema": {
+          "$schema": "http://json-schema.org/draft-04/schema"
         },
-        {
-            "stream": {
-                "name": "cash_balances_intraday",
-                "json_schema": {
-                    "$schema": "http://json-schema.org/draft-04/schema"
-                },
-                "supported_sync_modes": ["full_refresh"]
-            },
-            "sync_mode": "full_refresh",
-            "destination_sync_mode": "overwrite"
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "destination_sync_mode": "overwrite"
+    },
+    {
+      "stream": {
+        "name": "cash_balances_intraday",
+        "json_schema": {
+          "$schema": "http://json-schema.org/draft-04/schema"
         },
-        {
-            "stream": {
-                "name": "accounts",
-                "json_schema": {
-                    "$schema": "http://json-schema.org/draft-04/schema"
-                },
-                "supported_sync_modes": ["full_refresh"]
-            },
-            "sync_mode": "full_refresh",
-            "source_defined_primary_key": [["uuid"], ["code"]],
-            "destination_sync_mode": "overwrite"
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "destination_sync_mode": "overwrite"
+    },
+    {
+      "stream": {
+        "name": "accounts",
+        "json_schema": {
+          "$schema": "http://json-schema.org/draft-04/schema"
         },
-        {
-            "stream": {
-                "name": "cash_flows",
-                "json_schema": {
-                     "$schema": "http://json-schema.org/draft-04/schema"
-                },
-                "supported_sync_modes": ["full_refresh", "incremental"],
-                "source_defined_cursor": true,
-                "default_cursor_field": ["updateDateTime"]
-            },
-            "sync_mode": "incremental",
-            "source_defined_primary_key": [["uuid"]],
-            "destination_sync_mode": "append"
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "source_defined_primary_key": [["uuid"], ["code"]],
+      "destination_sync_mode": "overwrite"
+    },
+    {
+      "stream": {
+        "name": "cash_flows",
+        "json_schema": {
+          "$schema": "http://json-schema.org/draft-04/schema"
         },
-        {
-            "stream": {
-                "name": "cash_balances_eod",
-                "json_schema": {
-                    "$schema": "http://json-schema.org/draft-04/schema"
-                },
-                "supported_sync_modes": ["full_refresh"]
-            },
-            "sync_mode": "full_refresh",
-            "destination_sync_mode": "overwrite"
+        "supported_sync_modes": ["full_refresh", "incremental"],
+        "source_defined_cursor": true,
+        "default_cursor_field": ["updateDateTime"]
+      },
+      "sync_mode": "incremental",
+      "source_defined_primary_key": [["uuid"]],
+      "destination_sync_mode": "append"
+    },
+    {
+      "stream": {
+        "name": "cash_balances_eod",
+        "json_schema": {
+          "$schema": "http://json-schema.org/draft-04/schema"
         },
-        {
-            "stream": {
-                "name": "bank_balances_eod",
-                "json_schema": {
-                    "$schema": "http://json-schema.org/draft-04/schema"
-                },
-                "supported_sync_modes": ["full_refresh"]
-            },
-            "sync_mode": "full_refresh",
-            "destination_sync_mode": "overwrite"
-        }
-    ]
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "destination_sync_mode": "overwrite"
+    },
+    {
+      "stream": {
+        "name": "bank_balances_eod",
+        "json_schema": {
+          "$schema": "http://json-schema.org/draft-04/schema"
+        },
+        "supported_sync_modes": ["full_refresh"]
+      },
+      "sync_mode": "full_refresh",
+      "destination_sync_mode": "overwrite"
+    }
+  ]
 }
diff --git a/airbyte-integrations/connectors/source-kyriba/integration_tests/invalid_config.json b/airbyte-integrations/connectors/source-kyriba/integration_tests/invalid_config.json
@@ -1,7 +1,7 @@
 {
-    "username": "username",
-    "password": "password",
-    "start_date": "2022-05-01",
-    "end_date": "2022-05-04",
-    "domain": "demo.kyriba.com"
+  "username": "username",
+  "password": "password",
+  "start_date": "2022-05-01",
+  "end_date": "2022-05-04",
+  "domain": "demo.kyriba.com"
 }
diff --git a/airbyte-integrations/connectors/source-kyriba/integration_tests/sample_config.json b/airbyte-integrations/connectors/source-kyriba/integration_tests/sample_config.json
@@ -1,7 +1,7 @@
 {
-    "username": "username",
-    "password": "password",
-    "start_date": "2022-05-01",
-    "end_date": "2022-05-04",
-    "domain": "demo.kyriba.com"
+  "username": "username",
+  "password": "password",
+  "start_date": "2022-05-01",
+  "end_date": "2022-05-04",
+  "domain": "demo.kyriba.com"
 }
diff --git a/airbyte-integrations/connectors/source-kyriba/integration_tests/sample_state.json b/airbyte-integrations/connectors/source-kyriba/integration_tests/sample_state.json
@@ -1 +1 @@
-{"cash_flows": {"updateDateTime": "2022-05-04T18:31:18Z"}}
+{ "cash_flows": { "updateDateTime": "2022-05-04T18:31:18Z" } }