Skip to content

Commit 41b71e7

Browse files
committed
test(bigquery): verify batch count in arrow integration tests
1 parent f6bd8be commit 41b71e7

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

  • java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it

‎java-bigquery/google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/it/ITBigQueryTest.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7517,7 +7517,7 @@ void testQueryResultsFormatArrow() throws InterruptedException {
75177517
totalRows += root.getRowCount();
75187518
assertEquals(1, root.getRowCount());
75197519
}
7520-
assertTrue(batchCount > 0);
7520+
assertEquals(1, batchCount);
75217521
assertEquals(1, totalRows);
75227522
}
75237523
}
@@ -7532,10 +7532,13 @@ void testQueryResultsFormatArrowMultiPage() throws InterruptedException {
75327532
.build();
75337533
try (ArrowQueryResult result = bigquery.queryArrow(config)) {
75347534
assertNotNull(result);
7535+
int batchCount = 0;
75357536
long totalRows = 0;
75367537
for (VectorSchemaRoot root : result) {
7538+
batchCount++;
75377539
totalRows += root.getRowCount();
75387540
}
7541+
assertTrue(batchCount > 1);
75397542
assertEquals(15000, totalRows);
75407543
}
75417544
}

0 commit comments

Comments
 (0)