Skip to content

Commit 4640ad7

Browse files
yurii-bidiukyurii-bidiuk
committed
format code
1 parent 905e454 commit 4640ad7

File tree

8 files changed

+29
-26
lines changed

8 files changed

+29
-26
lines changed

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

+6-5
Original file line numberDiff line numberDiff line change
@@ -348,19 +348,20 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
348348
: "/" + String.join("/", pathFields.subList(0, pathFields.size() - 1));
349349
switch (dateTimeFieldNames.get(path)) {
350350
case DATE_TIME -> {
351-
if (pathFields.size() == 1)
351+
if (pathFields.size() == 1) {
352352
data.put(pathFields.get(0).toLowerCase(),
353-
DateTimeUtils.convertToBigqueryDenormalizedFormat((data.get(pathFields.get(0)).asText())));
354-
else {
353+
DateTimeUtils.convertToBigqueryDenormalizedFormat(
354+
(data.get(pathFields.get(0)).asText())));
355+
} else {
355356
((ObjectNode) data.at(pathWithoutLastField)).put(pathFields.get(pathFields.size() - 1),
356357
DateTimeUtils.convertToBigqueryDenormalizedFormat(data.at(path).asText()));
357358
}
358359
}
359360
case DATE -> {
360-
if (pathFields.size() == 1)
361+
if (pathFields.size() == 1) {
361362
data.put(pathFields.get(0).toLowerCase(),
362363
DateTimeUtils.convertToDateFormat(data.get(pathFields.get(0)).asText()));
363-
else {
364+
} else {
364365
((ObjectNode) data.at(pathWithoutLastField)).put(
365366
pathFields.get(pathFields.size() - 1),
366367
DateTimeUtils.convertToDateFormat((data.at(path).asText())));

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -92,10 +92,10 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
9292
}
9393
}
9494
case DATE -> {
95-
if (pathFields.size() == 1)
95+
if (pathFields.size() == 1) {
9696
data.put(pathFields.get(0).toLowerCase(),
9797
DateTimeUtils.convertToDateFormat(data.get(pathFields.get(0)).asText()));
98-
else {
98+
} else {
9999
((ObjectNode) data.at(pathWithoutLastField)).put(
100100
pathFields.get(pathFields.size() - 1).toLowerCase(),
101101
DateTimeUtils.convertToDateFormat((data.at(path).asText())));

‎airbyte-integrations/connectors/destination-databricks/src/test-integration/java/io/airbyte/integrations/destination/databricks/DatabricksDestinationAcceptanceTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -184,11 +184,11 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
184184
}
185185
}
186186
case DATE -> {
187-
if (pathFields.size() == 1)
187+
if (pathFields.size() == 1) {
188188
data.put(pathFields.get(0).toLowerCase(),
189189
String.format("{\"member0\":%s,\"member1\":null}",
190190
DateTimeUtils.convertToDateFormat(data.get(pathFields.get(0)).asText())));
191-
else {
191+
} else {
192192
((ObjectNode) data.at(pathWithoutLastField)).put(
193193
pathFields.get(pathFields.size() - 1).toLowerCase(),
194194
String.format("{\"member0\":%s,\"member1\":null}",

‎airbyte-integrations/connectors/destination-gcs/src/test-integration/java/io/airbyte/integrations/destination/gcs/GcsAvroDestinationAcceptanceTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -89,21 +89,21 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
8989
: "/" + String.join("/", pathFields.subList(0, pathFields.size() - 1));
9090
switch (dateTimeFieldNames.get(path)) {
9191
case DATE_TIME -> {
92-
if (pathFields.size() == 1)
92+
if (pathFields.size() == 1) {
9393
data.put(pathFields.get(0).toLowerCase(),
9494
(DateTimeUtils.getEpochMicros(data.get(pathFields.get(0)).asText()) / 1000)
9595
* 1000);
96-
else {
96+
} else {
9797
((ObjectNode) data.at(pathWithoutLastField)).put(
9898
pathFields.get(pathFields.size() - 1),
9999
(DateTimeUtils.getEpochMicros(data.at(path).asText()) / 1000) * 1000);
100100
}
101101
}
102102
case DATE -> {
103-
if (pathFields.size() == 1)
103+
if (pathFields.size() == 1) {
104104
data.put(pathFields.get(0).toLowerCase(),
105105
DateTimeUtils.getEpochDay(data.get(pathFields.get(0)).asText()));
106-
else {
106+
} else {
107107
((ObjectNode) data.at(pathWithoutLastField)).put(
108108
pathFields.get(pathFields.size() - 1),
109109
DateTimeUtils.getEpochDay((data.at(path).asText())));

‎airbyte-integrations/connectors/destination-gcs/src/test-integration/java/io/airbyte/integrations/destination/gcs/GcsParquetDestinationAcceptanceTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -96,22 +96,22 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
9696
: "/" + String.join("/", pathFields.subList(0, pathFields.size() - 1));
9797
switch (dateTimeFieldNames.get(path)) {
9898
case DATE_TIME -> {
99-
if (pathFields.size() == 1)
99+
if (pathFields.size() == 1) {
100100
data.put(pathFields.get(0).toLowerCase(),
101101
(DateTimeUtils.getEpochMicros(data.get(pathFields.get(0)).asText()) / 1000)
102102
* 1000);
103-
else {
103+
} else {
104104
((ObjectNode) data.at(pathWithoutLastField)).put(
105105
pathFields.get(pathFields.size() - 1),
106106
(DateTimeUtils.getEpochMicros(data.at(path).asText()) / 1000) * 1000);
107107
((ObjectNode) data.at(pathWithoutLastField)).set("_airbyte_additional_properties", null);
108108
}
109109
}
110110
case DATE -> {
111-
if (pathFields.size() == 1)
111+
if (pathFields.size() == 1) {
112112
data.put(pathFields.get(0).toLowerCase(),
113113
DateTimeUtils.getEpochDay(data.get(pathFields.get(0)).asText()));
114-
else {
114+
} else {
115115
((ObjectNode) data.at(pathWithoutLastField)).put(pathFields.get(pathFields.size() - 1),
116116
DateTimeUtils.getEpochDay((data.at(path).asText())));
117117
((ObjectNode) data.at(pathWithoutLastField)).set("_airbyte_additional_properties", null);

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

+3-1
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
import io.airbyte.integrations.standardtest.destination.DestinationAcceptanceTest;
4141
import java.io.ByteArrayInputStream;
4242
import java.io.IOException;
43+
import java.nio.charset.StandardCharsets;
4344
import java.nio.file.Files;
4445
import java.nio.file.Path;
4546
import java.util.List;
@@ -184,7 +185,8 @@ protected void setup(final TestDestinationEnv testEnv) throws Exception {
184185

185186
credentials =
186187
ServiceAccountCredentials
187-
.fromStream(new ByteArrayInputStream(configJson.get(CONFIG_CREDS).asText().getBytes()));
188+
.fromStream(new ByteArrayInputStream(configJson.get(CONFIG_CREDS).asText().getBytes(
189+
StandardCharsets.UTF_8)));
188190
// create topic
189191
topicName = TopicName.of(projectId, topicId);
190192
topicAdminClient = TopicAdminClient

‎airbyte-integrations/connectors/destination-s3/src/test-integration/java/io/airbyte/integrations/destination/s3/S3AvroDestinationAcceptanceTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -96,21 +96,21 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
9696
: "/" + String.join("/", pathFields.subList(0, pathFields.size() - 1));
9797
switch (dateTimeFieldNames.get(path)) {
9898
case DATE_TIME -> {
99-
if (pathFields.size() == 1)
99+
if (pathFields.size() == 1) {
100100
data.put(pathFields.get(0).toLowerCase(),
101101
(DateTimeUtils.getEpochMicros(data.get(pathFields.get(0)).asText()) / 1000)
102102
* 1000);
103-
else {
103+
} else {
104104
((ObjectNode) data.at(pathWithoutLastField)).put(
105105
pathFields.get(pathFields.size() - 1),
106106
(DateTimeUtils.getEpochMicros(data.at(path).asText()) / 1000) * 1000);
107107
}
108108
}
109109
case DATE -> {
110-
if (pathFields.size() == 1)
110+
if (pathFields.size() == 1) {
111111
data.put(pathFields.get(0).toLowerCase(),
112112
DateTimeUtils.getEpochDay(data.get(pathFields.get(0)).asText()));
113-
else {
113+
} else {
114114
((ObjectNode) data.at(pathWithoutLastField)).put(
115115
pathFields.get(pathFields.size() - 1),
116116
DateTimeUtils.getEpochDay((data.at(path).asText())));

‎airbyte-integrations/connectors/destination-s3/src/test-integration/java/io/airbyte/integrations/destination/s3/S3ParquetDestinationAcceptanceTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -100,21 +100,21 @@ public void convertDateTime(ObjectNode data, Map<String, String> dateTimeFieldNa
100100
: "/" + String.join("/", pathFields.subList(0, pathFields.size() - 1));
101101
switch (dateTimeFieldNames.get(path)) {
102102
case DATE_TIME -> {
103-
if (pathFields.size() == 1)
103+
if (pathFields.size() == 1) {
104104
data.put(pathFields.get(0).toLowerCase(),
105105
(DateTimeUtils.getEpochMicros(data.get(pathFields.get(0)).asText()) / 1000)
106106
* 1000);
107-
else {
107+
} else {
108108
((ObjectNode) data.at(pathWithoutLastField)).put(
109109
pathFields.get(pathFields.size() - 1),
110110
(DateTimeUtils.getEpochMicros(data.at(path).asText()) / 1000) * 1000);
111111
}
112112
}
113113
case DATE -> {
114-
if (pathFields.size() == 1)
114+
if (pathFields.size() == 1) {
115115
data.put(pathFields.get(0).toLowerCase(),
116116
DateTimeUtils.getEpochDay(data.get(pathFields.get(0)).asText()));
117-
else {
117+
} else {
118118
((ObjectNode) data.at(pathWithoutLastField)).put(pathFields.get(pathFields.size() - 1),
119119
DateTimeUtils.getEpochDay((data.at(path).asText())));
120120
}

0 commit comments

Comments
 (0)