Skip to content

Commit

Permalink
mvn spotless:apply
Browse files Browse the repository at this point in the history
  • Loading branch information
Tan-JiaLiang committed Jan 2, 2025
1 parent 3ba1d4b commit 35a9798
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1065,10 +1065,11 @@ public void testDeletionVectorsCombineWithFileIndexPushDownParquet() throws Exce
plan = table.newScan().plan();
reader = table.newRead().withFilter(predicate).createReader(plan.splits());
AtomicLong expectedCnt = new AtomicLong(0);
reader.forEachRemaining(row -> {
expectedCnt.incrementAndGet();
assertThat(row.getLong(2)).isEqualTo(expectedMap.get(row.getInt(1)));
});
reader.forEachRemaining(
row -> {
expectedCnt.incrementAndGet();
assertThat(row.getLong(2)).isEqualTo(expectedMap.get(row.getInt(1)));
});
long count =
expectedMap.entrySet().stream().filter(x -> x.getValue().equals(next)).count();
assertThat(expectedCnt.get()).isEqualTo(count);
Expand Down

0 comments on commit 35a9798

Please sign in to comment.