Skip to content

Commit

Permalink
spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
maxim_konstantinov committed Aug 14, 2024
1 parent 9157960 commit 3b722e4
Showing 1 changed file with 8 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -802,24 +802,19 @@ private void testOneInputFileManyInputFilesToJoin() throws IOException {
.build());

List<Long> rowGroupRowCounts = ParquetFileReader.readFooter(
conf,
new Path(inputFiles.get(0).getFileName()),
ParquetMetadataConverter.NO_FILTER
)
conf, new Path(inputFiles.get(0).getFileName()), ParquetMetadataConverter.NO_FILTER)
.getBlocks()
.stream()
.map(BlockMetaData::getRowCount)
.collect(Collectors.toList());

for (long count: rowGroupRowCounts) {
inputFilesToJoinColumns.add(
new TestFileBuilder(conf, createSchemaR())
.withNumRecord((int)count)
.withCodec("UNCOMPRESSED")
.withPageSize(ParquetProperties.DEFAULT_PAGE_SIZE)
.withWriterVersion(writerVersion)
.build()
);
for (long count : rowGroupRowCounts) {
inputFilesToJoinColumns.add(new TestFileBuilder(conf, createSchemaR())
.withNumRecord((int) count)
.withCodec("UNCOMPRESSED")
.withPageSize(ParquetProperties.DEFAULT_PAGE_SIZE)
.withWriterVersion(writerVersion)
.build());
}
}

Expand Down

0 comments on commit 3b722e4

Please sign in to comment.