Skip to content

Commit a5e625b

Browse files
suhomudsuhomud
authored
fix format (#19538)
1 parent e69ecf3 commit a5e625b

File tree

76 files changed

+599
-582
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

76 files changed

+599
-582
lines changed

‎airbyte-integrations/connectors/destination-azure-blob-storage/src/main/java/io/airbyte/integrations/destination/azure_blob_storage/AzureBlobStorageConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,14 +9,14 @@
99
import com.azure.storage.blob.specialized.SpecializedBlobClientBuilder;
1010
import com.azure.storage.common.StorageSharedKeyCredential;
1111
import io.airbyte.commons.json.Jsons;
12-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1312
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1413
import io.airbyte.integrations.destination.azure_blob_storage.writer.AzureBlobStorageWriter;
1514
import io.airbyte.integrations.destination.azure_blob_storage.writer.AzureBlobStorageWriterFactory;
1615
import io.airbyte.protocol.models.AirbyteMessage;
1716
import io.airbyte.protocol.models.AirbyteMessage.Type;
1817
import io.airbyte.protocol.models.AirbyteRecordMessage;
1918
import io.airbyte.protocol.models.AirbyteStream;
19+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2020
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2121
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
2222
import io.airbyte.protocol.models.DestinationSyncMode;

‎airbyte-integrations/connectors/destination-bigquery-denormalized/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDenormalizedDestination.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
import com.fasterxml.jackson.databind.JsonNode;
1010
import com.google.cloud.bigquery.Field;
1111
import com.google.cloud.bigquery.Table;
12-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1312
import io.airbyte.integrations.base.Destination;
1413
import io.airbyte.integrations.base.IntegrationRunner;
1514
import io.airbyte.integrations.destination.bigquery.formatter.BigQueryRecordFormatter;
@@ -22,6 +21,7 @@
2221
import io.airbyte.integrations.destination.bigquery.uploader.config.UploaderConfig;
2322
import io.airbyte.integrations.destination.s3.avro.JsonToAvroSchemaConverter;
2423
import io.airbyte.protocol.models.AirbyteStream;
24+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2525
import java.io.IOException;
2626
import java.util.Map;
2727
import java.util.function.BiFunction;

‎airbyte-integrations/connectors/destination-bigquery-denormalized/src/test/java/io/airbyte/integrations/destination/bigquery/BigQueryDenormalizedDestinationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import com.google.cloud.bigquery.StandardSQLTypeName;
2929
import com.google.cloud.bigquery.Table;
3030
import com.google.cloud.bigquery.TableDefinition;
31-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
3231
import io.airbyte.integrations.destination.bigquery.formatter.BigQueryRecordFormatter;
3332
import io.airbyte.integrations.destination.bigquery.formatter.DefaultBigQueryDenormalizedRecordFormatter;
3433
import io.airbyte.integrations.destination.bigquery.formatter.GcsBigQueryDenormalizedRecordFormatter;
@@ -39,6 +38,7 @@
3938
import io.airbyte.integrations.destination.bigquery.uploader.UploaderType;
4039
import io.airbyte.integrations.destination.bigquery.uploader.config.UploaderConfig;
4140
import io.airbyte.protocol.models.AirbyteStream;
41+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
4242
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
4343
import java.io.IOException;
4444
import java.util.HashMap;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,14 @@
66

77
import com.fasterxml.jackson.databind.JsonNode;
88
import io.airbyte.commons.functional.CheckedBiFunction;
9-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
109
import io.airbyte.integrations.destination.bigquery.formatter.BigQueryRecordFormatter;
1110
import io.airbyte.integrations.destination.record_buffer.BufferStorage;
1211
import io.airbyte.integrations.destination.record_buffer.SerializableBuffer;
1312
import io.airbyte.integrations.destination.s3.avro.AvroSerializedBuffer;
1413
import io.airbyte.integrations.destination.s3.avro.S3AvroFormatConfig;
1514
import io.airbyte.protocol.models.AirbyteRecordMessage;
1615
import io.airbyte.protocol.models.AirbyteStream;
16+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1717
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1818
import java.io.IOException;
1919
import java.util.concurrent.Callable;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import io.airbyte.commons.json.Jsons;
2121
import io.airbyte.integrations.BaseConnector;
2222
import io.airbyte.integrations.base.AirbyteMessageConsumer;
23-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2423
import io.airbyte.integrations.base.Destination;
2524
import io.airbyte.integrations.base.IntegrationRunner;
2625
import io.airbyte.integrations.destination.StandardNameTransformer;
@@ -44,6 +43,7 @@
4443
import io.airbyte.protocol.models.AirbyteConnectionStatus.Status;
4544
import io.airbyte.protocol.models.AirbyteMessage;
4645
import io.airbyte.protocol.models.AirbyteStream;
46+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
4747
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
4848
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
4949
import java.io.ByteArrayInputStream;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,11 @@
66

77
import io.airbyte.commons.string.Strings;
88
import io.airbyte.integrations.base.AirbyteMessageConsumer;
9-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
109
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1110
import io.airbyte.integrations.destination.bigquery.uploader.AbstractBigQueryUploader;
1211
import io.airbyte.protocol.models.AirbyteMessage;
1312
import io.airbyte.protocol.models.AirbyteMessage.Type;
13+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1414
import java.util.ArrayList;
1515
import java.util.List;
1616
import java.util.Map;

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,13 +13,13 @@
1313
import io.airbyte.commons.functional.CheckedConsumer;
1414
import io.airbyte.commons.json.Jsons;
1515
import io.airbyte.integrations.base.AirbyteMessageConsumer;
16-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1716
import io.airbyte.integrations.destination.bigquery.formatter.BigQueryRecordFormatter;
1817
import io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer;
1918
import io.airbyte.integrations.destination.record_buffer.SerializableBuffer;
2019
import io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy;
2120
import io.airbyte.protocol.models.AirbyteMessage;
2221
import io.airbyte.protocol.models.AirbyteStream;
22+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2323
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2424
import java.util.Map;
2525
import java.util.function.Consumer;

‎airbyte-integrations/connectors/destination-bigquery/src/test/java/io/airbyte/integrations/destination/bigquery/BigQueryRecordConsumerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,11 +4,11 @@
44

55
package io.airbyte.integrations.destination.bigquery;
66

7-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
87
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
98
import io.airbyte.integrations.destination.bigquery.uploader.AbstractBigQueryUploader;
109
import io.airbyte.integrations.standardtest.destination.PerStreamStateMessageTest;
1110
import io.airbyte.protocol.models.AirbyteMessage;
11+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1212
import java.util.Map;
1313
import java.util.function.Consumer;
1414
import org.junit.jupiter.api.extension.ExtendWith;

‎airbyte-integrations/connectors/destination-cassandra/src/main/java/io/airbyte/integrations/destination/cassandra/CassandraMessageConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
package io.airbyte.integrations.destination.cassandra;
66

77
import io.airbyte.commons.json.Jsons;
8-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
98
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
109
import io.airbyte.protocol.models.AirbyteMessage;
10+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1111
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1212
import java.util.Map;
1313
import java.util.function.Consumer;

‎airbyte-integrations/connectors/destination-dynamodb/src/main/java/io/airbyte/integrations/destination/dynamodb/DynamodbConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@
1212
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
1313
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
1414
import io.airbyte.commons.json.Jsons;
15-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1615
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1716
import io.airbyte.protocol.models.*;
17+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1818
import java.util.*;
1919
import java.util.function.Consumer;
2020
import org.slf4j.Logger;

‎airbyte-integrations/connectors/destination-e2e-test/src/main/java/io/airbyte/integrations/destination/e2e_test/logging/BaseLogger.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
package io.airbyte.integrations.destination.e2e_test.logging;
66

7-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
87
import io.airbyte.protocol.models.AirbyteRecordMessage;
8+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
99
import java.time.Instant;
1010
import java.time.OffsetDateTime;
1111
import java.time.ZoneId;

‎airbyte-integrations/connectors/destination-e2e-test/src/main/java/io/airbyte/integrations/destination/e2e_test/logging/EveryNthLogger.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
package io.airbyte.integrations.destination.e2e_test.logging;
66

7-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
87
import io.airbyte.protocol.models.AirbyteRecordMessage;
8+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
99
import org.slf4j.Logger;
1010
import org.slf4j.LoggerFactory;
1111

‎airbyte-integrations/connectors/destination-e2e-test/src/main/java/io/airbyte/integrations/destination/e2e_test/logging/FirstNLogger.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
package io.airbyte.integrations.destination.e2e_test.logging;
66

7-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
87
import io.airbyte.protocol.models.AirbyteRecordMessage;
8+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
99
import org.slf4j.Logger;
1010
import org.slf4j.LoggerFactory;
1111

‎airbyte-integrations/connectors/destination-e2e-test/src/main/java/io/airbyte/integrations/destination/e2e_test/logging/LoggingConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,11 @@
66

77
import io.airbyte.commons.json.Jsons;
88
import io.airbyte.integrations.base.AirbyteMessageConsumer;
9-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
109
import io.airbyte.protocol.models.AirbyteMessage;
1110
import io.airbyte.protocol.models.AirbyteMessage.Type;
1211
import io.airbyte.protocol.models.AirbyteRecordMessage;
1312
import io.airbyte.protocol.models.AirbyteStream;
13+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1414
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1515
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
1616
import java.util.HashMap;

‎airbyte-integrations/connectors/destination-e2e-test/src/main/java/io/airbyte/integrations/destination/e2e_test/logging/RandomSamplingLogger.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
package io.airbyte.integrations.destination.e2e_test.logging;
66

7-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
87
import io.airbyte.protocol.models.AirbyteRecordMessage;
8+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
99
import java.util.Random;
1010
import org.slf4j.Logger;
1111
import org.slf4j.LoggerFactory;

‎airbyte-integrations/connectors/destination-e2e-test/src/main/java/io/airbyte/integrations/destination/e2e_test/logging/TestingLoggerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
package io.airbyte.integrations.destination.e2e_test.logging;
66

77
import com.fasterxml.jackson.databind.JsonNode;
8-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
98
import io.airbyte.integrations.destination.e2e_test.logging.TestingLogger.LoggingType;
9+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1010

1111
public class TestingLoggerFactory {
1212

‎airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/JdbcBufferedConsumerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import io.airbyte.db.jdbc.JdbcDatabase;
1313
import io.airbyte.db.jdbc.JdbcUtils;
1414
import io.airbyte.integrations.base.AirbyteMessageConsumer;
15-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1615
import io.airbyte.integrations.destination.NamingConventionTransformer;
1716
import io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer;
1817
import io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction;
@@ -22,6 +21,7 @@
2221
import io.airbyte.protocol.models.AirbyteMessage;
2322
import io.airbyte.protocol.models.AirbyteRecordMessage;
2423
import io.airbyte.protocol.models.AirbyteStream;
24+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2525
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2626
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
2727
import io.airbyte.protocol.models.DestinationSyncMode;

‎airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/jdbc/copy/CopyConsumerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
import io.airbyte.db.factory.DataSourceFactory;
1010
import io.airbyte.db.jdbc.JdbcDatabase;
1111
import io.airbyte.integrations.base.AirbyteMessageConsumer;
12-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1312
import io.airbyte.integrations.destination.ExtendedNameTransformer;
1413
import io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer;
1514
import io.airbyte.integrations.destination.buffered_stream_consumer.CheckAndRemoveRecordWriter;
@@ -20,6 +19,7 @@
2019
import io.airbyte.integrations.destination.record_buffer.InMemoryRecordBufferingStrategy;
2120
import io.airbyte.protocol.models.AirbyteMessage;
2221
import io.airbyte.protocol.models.AirbyteRecordMessage;
22+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2323
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2424
import java.util.ArrayList;
2525
import java.util.HashMap;

‎airbyte-integrations/connectors/destination-jdbc/src/main/java/io/airbyte/integrations/destination/staging/StagingConsumerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import io.airbyte.commons.json.Jsons;
1212
import io.airbyte.db.jdbc.JdbcDatabase;
1313
import io.airbyte.integrations.base.AirbyteMessageConsumer;
14-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1514
import io.airbyte.integrations.destination.NamingConventionTransformer;
1615
import io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer;
1716
import io.airbyte.integrations.destination.buffered_stream_consumer.OnCloseFunction;
@@ -21,6 +20,7 @@
2120
import io.airbyte.integrations.destination.record_buffer.SerializedBufferingStrategy;
2221
import io.airbyte.protocol.models.AirbyteMessage;
2322
import io.airbyte.protocol.models.AirbyteStream;
23+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2424
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2525
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
2626
import io.airbyte.protocol.models.DestinationSyncMode;

‎airbyte-integrations/connectors/destination-kafka/src/main/java/io/airbyte/integrations/destination/kafka/KafkaRecordConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,11 @@
77
import com.fasterxml.jackson.databind.JsonNode;
88
import com.google.common.collect.ImmutableMap;
99
import io.airbyte.commons.json.Jsons;
10-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1110
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1211
import io.airbyte.integrations.destination.NamingConventionTransformer;
1312
import io.airbyte.protocol.models.AirbyteMessage;
1413
import io.airbyte.protocol.models.AirbyteRecordMessage;
14+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1515
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1616
import java.util.HashMap;
1717
import java.util.Map;

‎airbyte-integrations/connectors/destination-kafka/src/test/java/io/airbyte/integrations/destination/kafka/KafkaRecordConsumerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,13 +13,13 @@
1313
import com.google.common.collect.ImmutableMap;
1414
import io.airbyte.commons.jackson.MoreMappers;
1515
import io.airbyte.commons.json.Jsons;
16-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1716
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1817
import io.airbyte.integrations.destination.StandardNameTransformer;
1918
import io.airbyte.integrations.standardtest.destination.PerStreamStateMessageTest;
2019
import io.airbyte.protocol.models.AirbyteMessage;
2120
import io.airbyte.protocol.models.AirbyteRecordMessage;
2221
import io.airbyte.protocol.models.AirbyteStateMessage;
22+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2323
import io.airbyte.protocol.models.CatalogHelpers;
2424
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2525
import io.airbyte.protocol.models.Field;

‎airbyte-integrations/connectors/destination-kinesis/src/main/java/io/airbyte/integrations/destination/kinesis/KinesisMessageConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
package io.airbyte.integrations.destination.kinesis;
66

77
import io.airbyte.commons.json.Jsons;
8-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
98
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
109
import io.airbyte.protocol.models.AirbyteMessage;
10+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1111
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1212
import java.time.Instant;
1313
import java.util.Map;

‎airbyte-integrations/connectors/destination-mongodb/src/main/java/io/airbyte/integrations/destination/mongodb/MongodbDestination.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import io.airbyte.db.mongodb.MongoUtils.MongoInstanceType;
2323
import io.airbyte.integrations.BaseConnector;
2424
import io.airbyte.integrations.base.AirbyteMessageConsumer;
25-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2625
import io.airbyte.integrations.base.AirbyteTraceMessageUtility;
2726
import io.airbyte.integrations.base.Destination;
2827
import io.airbyte.integrations.base.IntegrationRunner;
@@ -31,6 +30,7 @@
3130
import io.airbyte.protocol.models.AirbyteConnectionStatus;
3231
import io.airbyte.protocol.models.AirbyteMessage;
3332
import io.airbyte.protocol.models.AirbyteStream;
33+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
3434
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
3535
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
3636
import io.airbyte.protocol.models.DestinationSyncMode;

‎airbyte-integrations/connectors/destination-mongodb/src/main/java/io/airbyte/integrations/destination/mongodb/MongodbRecordConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,10 +13,10 @@
1313
import io.airbyte.commons.lang.Exceptions;
1414
import io.airbyte.db.mongodb.MongoDatabase;
1515
import io.airbyte.integrations.base.AirbyteMessageConsumer;
16-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1716
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1817
import io.airbyte.protocol.models.AirbyteMessage;
1918
import io.airbyte.protocol.models.AirbyteRecordMessage;
19+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2020
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2121
import java.nio.charset.Charset;
2222
import java.util.ArrayList;

‎airbyte-integrations/connectors/destination-mongodb/src/test/java/io/airbyte/integrations/destination/mongodb/MongodbRecordConsumerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,10 @@
55
package io.airbyte.integrations.destination.mongodb;
66

77
import io.airbyte.db.mongodb.MongoDatabase;
8-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
98
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
109
import io.airbyte.integrations.standardtest.destination.PerStreamStateMessageTest;
1110
import io.airbyte.protocol.models.AirbyteMessage;
11+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1212
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1313
import java.util.Map;
1414
import java.util.function.Consumer;

‎airbyte-integrations/connectors/destination-mqtt/src/main/java/io/airbyte/integrations/destination/mqtt/MqttRecordConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,10 +9,10 @@
99
import com.google.common.collect.ImmutableMap;
1010
import io.airbyte.commons.json.Jsons;
1111
import io.airbyte.commons.lang.Exceptions;
12-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1312
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
1413
import io.airbyte.protocol.models.AirbyteMessage;
1514
import io.airbyte.protocol.models.AirbyteRecordMessage;
15+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1616
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1717
import java.util.HashMap;
1818
import java.util.Map;

‎airbyte-integrations/connectors/destination-mqtt/src/test/java/io/airbyte/integrations/destination/mqtt/MqttRecordConsumerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,11 @@
1414
import com.google.common.collect.Sets;
1515
import com.hivemq.testcontainer.junit5.HiveMQTestContainerExtension;
1616
import io.airbyte.commons.json.Jsons;
17-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1817
import io.airbyte.protocol.models.AirbyteMessage;
1918
import io.airbyte.protocol.models.AirbyteRecordMessage;
2019
import io.airbyte.protocol.models.AirbyteStateMessage;
2120
import io.airbyte.protocol.models.AirbyteStream;
21+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2222
import io.airbyte.protocol.models.CatalogHelpers;
2323
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2424
import io.airbyte.protocol.models.ConfiguredAirbyteStream;

‎airbyte-integrations/connectors/destination-pubsub/src/main/java/io/airbyte/integrations/destination/pubsub/PubsubConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,12 @@
1616
import com.google.pubsub.v1.PubsubMessage;
1717
import com.google.pubsub.v1.TopicName;
1818
import io.airbyte.commons.json.Jsons;
19-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2019
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
2120
import io.airbyte.integrations.base.JavaBaseConstants;
2221
import io.airbyte.protocol.models.AirbyteMessage;
2322
import io.airbyte.protocol.models.AirbyteMessage.Type;
2423
import io.airbyte.protocol.models.AirbyteRecordMessage;
24+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
2525
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
2626
import io.airbyte.protocol.models.ConfiguredAirbyteStream;
2727
import java.io.ByteArrayInputStream;

‎airbyte-integrations/connectors/destination-pubsub/src/test-integration/java/io/airbyte/integrations/destination/pubsub/PubsubDestinationAcceptanceTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,11 @@
3535
import com.google.pubsub.v1.TopicName;
3636
import io.airbyte.commons.json.Jsons;
3737
import io.airbyte.commons.string.Strings;
38-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
3938
import io.airbyte.integrations.base.JavaBaseConstants;
4039
import io.airbyte.integrations.standardtest.destination.DestinationAcceptanceTest;
4140
import io.airbyte.integrations.standardtest.destination.comparator.AdvancedTestDataComparator;
4241
import io.airbyte.integrations.standardtest.destination.comparator.TestDataComparator;
42+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
4343
import java.io.ByteArrayInputStream;
4444
import java.io.IOException;
4545
import java.nio.charset.StandardCharsets;

‎airbyte-integrations/connectors/destination-pulsar/src/main/java/io/airbyte/integrations/destination/pulsar/PulsarRecordConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,11 @@
55
package io.airbyte.integrations.destination.pulsar;
66

77
import io.airbyte.commons.lang.Exceptions;
8-
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
98
import io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer;
109
import io.airbyte.integrations.destination.NamingConventionTransformer;
1110
import io.airbyte.protocol.models.AirbyteMessage;
1211
import io.airbyte.protocol.models.AirbyteRecordMessage;
12+
import io.airbyte.protocol.models.AirbyteStreamNameNamespacePair;
1313
import io.airbyte.protocol.models.ConfiguredAirbyteCatalog;
1414
import java.nio.charset.StandardCharsets;
1515
import java.util.HashMap;

0 commit comments

Comments
 (0)