Skip to content

Commit

Permalink
Address comments
Browse files Browse the repository at this point in the history
Signed-off-by: Firestarman <[email protected]>
  • Loading branch information
firestarman committed Nov 15, 2023
1 parent bbedcf8 commit 5967239
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -319,6 +319,8 @@ protected FilteredParquetFileInfo filterParquetBlocks(FileScanTask fst,
GpuParquetReader.addNullsForMissingFields(idToConstant, reorder.getMissingFields());

ParquetFileInfoWithBlockMeta parquetBlockMeta = ParquetFileInfoWithBlockMeta.apply(
// The path conversion aligns with that in Rapids multi-files readers.
// So here should use the file path of a PartitionedFile.
new Path(new URI(partFilePathString)), clippedBlocks,
InternalRow.empty(), fileReadSchema, partReaderSparkSchema,
DateTimeRebaseCorrected$.MODULE$, // dateRebaseMode
Expand Down

0 comments on commit 5967239

Please sign in to comment.