Skip to content

Commit 6f7b33e

Browse files
rtadepallirtadepalli
committed
run mvn spotless:apply
1 parent ef86c7d commit 6f7b33e

File tree

3 files changed

+56
-54
lines changed

3 files changed

+56
-54
lines changed

‎flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/test/TestFlightSql.java‎

Lines changed: 44 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -247,15 +247,14 @@ private static List<List<String>> getNonConformingResultsForGetSqlInfo(
247247
@Test
248248
public void testGetTablesSchema() {
249249
final FlightInfo info = sqlClient.getTables(null, null, null, null, true);
250-
Assertions.assertThat(
251-
info.getSchemaOptional()).isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA));
250+
Assertions.assertThat(info.getSchemaOptional())
251+
.isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA));
252252
}
253253

254254
@Test
255255
public void testGetTablesSchemaExcludeSchema() {
256256
final FlightInfo info = sqlClient.getTables(null, null, null, null, false);
257-
Assertions.assertThat(
258-
info.getSchemaOptional())
257+
Assertions.assertThat(info.getSchemaOptional())
259258
.isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA));
260259
}
261260

@@ -266,8 +265,8 @@ public void testGetTablesResultNoSchema() throws Exception {
266265
sqlClient.getTables(null, null, null, null, false).getEndpoints().get(0).getTicket())) {
267266
assertAll(
268267
() -> {
269-
Assertions.assertThat(
270-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA);
268+
Assertions.assertThat(stream.getSchema())
269+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA);
271270
},
272271
() -> {
273272
final List<List<String>> results = getResults(stream);
@@ -318,8 +317,8 @@ public void testGetTablesResultFilteredNoSchema() throws Exception {
318317

319318
assertAll(
320319
() ->
321-
Assertions.assertThat(
322-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA),
320+
Assertions.assertThat(stream.getSchema())
321+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA),
323322
() -> {
324323
final List<List<String>> results = getResults(stream);
325324
final List<List<String>> expectedResults =
@@ -343,10 +342,11 @@ public void testGetTablesResultFilteredWithSchema() throws Exception {
343342
.getTicket())) {
344343
assertAll(
345344
() ->
346-
Assertions.assertThat(stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA),
345+
Assertions.assertThat(stream.getSchema())
346+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA),
347347
() -> {
348-
Assertions.assertThat(
349-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA);
348+
Assertions.assertThat(stream.getSchema())
349+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA);
350350
final List<List<String>> results = getResults(stream);
351351
final List<List<String>> expectedResults =
352352
ImmutableList.of(
@@ -501,7 +501,8 @@ public void testSimplePreparedStatementSchema() throws Exception {
501501
},
502502
() -> {
503503
final FlightInfo info = preparedStatement.execute();
504-
Assertions.assertThat(info.getSchemaOptional()).isEqualTo(Optional.of(SCHEMA_INT_TABLE));
504+
Assertions.assertThat(info.getSchemaOptional())
505+
.isEqualTo(Optional.of(SCHEMA_INT_TABLE));
505506
});
506507
}
507508
}
@@ -514,8 +515,8 @@ public void testSimplePreparedStatementResults() throws Exception {
514515
assertAll(
515516
() -> Assertions.assertThat(stream.getSchema()).isEqualTo(SCHEMA_INT_TABLE),
516517
() ->
517-
Assertions.assertThat(
518-
getResults(stream)).isEqualTo(EXPECTED_RESULTS_FOR_STAR_SELECT_QUERY));
518+
Assertions.assertThat(getResults(stream))
519+
.isEqualTo(EXPECTED_RESULTS_FOR_STAR_SELECT_QUERY));
519520
}
520521
}
521522

@@ -539,8 +540,8 @@ public void testSimplePreparedStatementResultsWithParameterBinding() throws Exce
539540
assertAll(
540541
() -> Assertions.assertThat(stream.getSchema()).isEqualTo(SCHEMA_INT_TABLE),
541542
() ->
542-
Assertions.assertThat(
543-
getResults(stream)).isEqualTo(EXPECTED_RESULTS_FOR_PARAMETER_BINDING));
543+
Assertions.assertThat(getResults(stream))
544+
.isEqualTo(EXPECTED_RESULTS_FOR_PARAMETER_BINDING));
544545
}
545546
}
546547
}
@@ -729,8 +730,8 @@ public void testSimplePreparedStatementClosesProperly() {
729730
@Test
730731
public void testGetCatalogsSchema() {
731732
final FlightInfo info = sqlClient.getCatalogs();
732-
Assertions.assertThat(
733-
info.getSchemaOptional()).isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_CATALOGS_SCHEMA));
733+
Assertions.assertThat(info.getSchemaOptional())
734+
.isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_CATALOGS_SCHEMA));
734735
}
735736

736737
@Test
@@ -739,8 +740,8 @@ public void testGetCatalogsResults() throws Exception {
739740
sqlClient.getStream(sqlClient.getCatalogs().getEndpoints().get(0).getTicket())) {
740741
assertAll(
741742
() ->
742-
Assertions.assertThat(
743-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_CATALOGS_SCHEMA),
743+
Assertions.assertThat(stream.getSchema())
744+
.isEqualTo(FlightSqlProducer.Schemas.GET_CATALOGS_SCHEMA),
744745
() -> {
745746
List<List<String>> catalogs = getResults(stream);
746747
Assertions.assertThat(catalogs).isEqualTo(emptyList());
@@ -751,8 +752,7 @@ public void testGetCatalogsResults() throws Exception {
751752
@Test
752753
public void testGetTableTypesSchema() {
753754
final FlightInfo info = sqlClient.getTableTypes();
754-
Assertions.assertThat(
755-
info.getSchemaOptional())
755+
Assertions.assertThat(info.getSchemaOptional())
756756
.isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA));
757757
}
758758

@@ -762,8 +762,8 @@ public void testGetTableTypesResult() throws Exception {
762762
sqlClient.getStream(sqlClient.getTableTypes().getEndpoints().get(0).getTicket())) {
763763
assertAll(
764764
() -> {
765-
Assertions.assertThat(
766-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA);
765+
Assertions.assertThat(stream.getSchema())
766+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA);
767767
},
768768
() -> {
769769
final List<List<String>> tableTypes = getResults(stream);
@@ -782,8 +782,8 @@ public void testGetTableTypesResult() throws Exception {
782782
@Test
783783
public void testGetSchemasSchema() {
784784
final FlightInfo info = sqlClient.getSchemas(null, null);
785-
Assertions.assertThat(
786-
info.getSchemaOptional()).isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_SCHEMAS_SCHEMA));
785+
Assertions.assertThat(info.getSchemaOptional())
786+
.isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_SCHEMAS_SCHEMA));
787787
}
788788

789789
@Test
@@ -792,8 +792,8 @@ public void testGetSchemasResult() throws Exception {
792792
sqlClient.getStream(sqlClient.getSchemas(null, null).getEndpoints().get(0).getTicket())) {
793793
assertAll(
794794
() -> {
795-
Assertions.assertThat(
796-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_SCHEMAS_SCHEMA);
795+
Assertions.assertThat(stream.getSchema())
796+
.isEqualTo(FlightSqlProducer.Schemas.GET_SCHEMAS_SCHEMA);
797797
},
798798
() -> {
799799
final List<List<String>> schemas = getResults(stream);
@@ -840,8 +840,8 @@ public void testGetPrimaryKey() {
840840
@Test
841841
public void testGetSqlInfoSchema() {
842842
final FlightInfo info = sqlClient.getSqlInfo();
843-
Assertions.assertThat(
844-
info.getSchemaOptional()).isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA));
843+
Assertions.assertThat(info.getSchemaOptional())
844+
.isEqualTo(Optional.of(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA));
845845
}
846846

847847
@Test
@@ -850,11 +850,11 @@ public void testGetSqlInfoResults() throws Exception {
850850
try (final FlightStream stream = sqlClient.getStream(info.getEndpoints().get(0).getTicket())) {
851851
assertAll(
852852
() ->
853-
Assertions.assertThat(
854-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
853+
Assertions.assertThat(stream.getSchema())
854+
.isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
855855
() ->
856-
Assertions.assertThat(
857-
getNonConformingResultsForGetSqlInfo(getResults(stream))).isEqualTo(emptyList()));
856+
Assertions.assertThat(getNonConformingResultsForGetSqlInfo(getResults(stream)))
857+
.isEqualTo(emptyList()));
858858
}
859859
}
860860

@@ -865,11 +865,11 @@ public void testGetSqlInfoResultsWithSingleArg() throws Exception {
865865
try (final FlightStream stream = sqlClient.getStream(info.getEndpoints().get(0).getTicket())) {
866866
assertAll(
867867
() ->
868-
Assertions.assertThat(
869-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
868+
Assertions.assertThat(stream.getSchema())
869+
.isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
870870
() ->
871-
Assertions.assertThat(
872-
getNonConformingResultsForGetSqlInfo(getResults(stream), arg)).isEqualTo(emptyList()));
871+
Assertions.assertThat(getNonConformingResultsForGetSqlInfo(getResults(stream), arg))
872+
.isEqualTo(emptyList()));
873873
}
874874
}
875875

@@ -894,11 +894,11 @@ public void testGetSqlInfoResultsWithManyArgs() throws Exception {
894894
try (final FlightStream stream = sqlClient.getStream(info.getEndpoints().get(0).getTicket())) {
895895
assertAll(
896896
() ->
897-
Assertions.assertThat(
898-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
897+
Assertions.assertThat(stream.getSchema())
898+
.isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
899899
() ->
900-
Assertions.assertThat(
901-
getNonConformingResultsForGetSqlInfo(getResults(stream), args)).isEqualTo(emptyList()));
900+
Assertions.assertThat(getNonConformingResultsForGetSqlInfo(getResults(stream), args))
901+
.isEqualTo(emptyList()));
902902
}
903903
}
904904

@@ -1528,8 +1528,8 @@ public void testCreateStatementResults() throws Exception {
15281528
Assertions.assertThat(stream.getSchema()).isEqualTo(SCHEMA_INT_TABLE);
15291529
},
15301530
() -> {
1531-
Assertions.assertThat(
1532-
getResults(stream)).isEqualTo(EXPECTED_RESULTS_FOR_STAR_SELECT_QUERY);
1531+
Assertions.assertThat(getResults(stream))
1532+
.isEqualTo(EXPECTED_RESULTS_FOR_STAR_SELECT_QUERY);
15331533
});
15341534
}
15351535
}

‎flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/test/TestFlightSqlStateless.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,8 @@ public void testSimplePreparedStatementResultsWithParameterBinding() throws Exce
9090
assertAll(
9191
() -> Assertions.assertThat(stream.getSchema()).isEqualTo(SCHEMA_INT_TABLE),
9292
() ->
93-
Assertions.assertThat(
94-
getResults(stream)).isEqualTo(EXPECTED_RESULTS_FOR_PARAMETER_BINDING));
93+
Assertions.assertThat(getResults(stream))
94+
.isEqualTo(EXPECTED_RESULTS_FOR_PARAMETER_BINDING));
9595
}
9696
}
9797
}

‎flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/test/TestFlightSqlStreams.java‎

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -244,8 +244,8 @@ public void testGetTablesResultNoSchema() throws Exception {
244244
sqlClient.getTables(null, null, null, null, false).getEndpoints().get(0).getTicket())) {
245245
assertAll(
246246
() ->
247-
Assertions.assertThat(
248-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA),
247+
Assertions.assertThat(stream.getSchema())
248+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLES_SCHEMA_NO_SCHEMA),
249249
() -> {
250250
final List<List<String>> results = getResults(stream);
251251
final List<List<String>> expectedResults =
@@ -263,8 +263,8 @@ public void testGetTableTypesResult() throws Exception {
263263
sqlClient.getStream(sqlClient.getTableTypes().getEndpoints().get(0).getTicket())) {
264264
assertAll(
265265
() ->
266-
Assertions.assertThat(
267-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA),
266+
Assertions.assertThat(stream.getSchema())
267+
.isEqualTo(FlightSqlProducer.Schemas.GET_TABLE_TYPES_SCHEMA),
268268
() -> {
269269
final List<List<String>> tableTypes = getResults(stream);
270270
final List<List<String>> expectedTableTypes =
@@ -282,8 +282,8 @@ public void testGetSqlInfoResults() throws Exception {
282282
try (final FlightStream stream = sqlClient.getStream(info.getEndpoints().get(0).getTicket())) {
283283
assertAll(
284284
() ->
285-
Assertions.assertThat(
286-
stream.getSchema()).isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
285+
Assertions.assertThat(stream.getSchema())
286+
.isEqualTo(FlightSqlProducer.Schemas.GET_SQL_INFO_SCHEMA),
287287
() -> Assertions.assertThat(getResults(stream)).isEqualTo(emptyList()));
288288
}
289289
}
@@ -317,9 +317,11 @@ public void testExecuteQuery() throws Exception {
317317
.getTicket())) {
318318
assertAll(
319319
() ->
320-
Assertions.assertThat(stream.getSchema()).isEqualTo(FlightSqlTestProducer.FIXED_SCHEMA),
320+
Assertions.assertThat(stream.getSchema())
321+
.isEqualTo(FlightSqlTestProducer.FIXED_SCHEMA),
321322
() ->
322-
Assertions.assertThat(getResults(stream)).isEqualTo(singletonList(singletonList("1"))));
323+
Assertions.assertThat(getResults(stream))
324+
.isEqualTo(singletonList(singletonList("1"))));
323325
}
324326
}
325327
}

0 commit comments

Comments
 (0)