Package io.delta.kernel.defaults.internal.parquet

Class ParquetFileReader

Object
io.delta.kernel.defaults.internal.parquet.ParquetFileReader
public class ParquetFileReader extends Object

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    ParquetFileReader.BatchReadSupport
    Implement a ReadSupport that will collect the data for each row and return as a ColumnarBatch.
    static class 
    ParquetFileReader.RowRecordCollector
    Collects the records given by the Parquet reader as columnar data.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ParquetFileReader(FileIO fileIO)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.delta.kernel.utils.CloseableIterator<io.delta.kernel.data.ColumnarBatch>
    read(io.delta.kernel.utils.FileStatus fileStatus, io.delta.kernel.types.StructType schema, Optional<io.delta.kernel.expressions.Predicate> predicate)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ParquetFileReader

      public ParquetFileReader(FileIO fileIO)

  • Method Details

    • read

      public io.delta.kernel.utils.CloseableIterator<io.delta.kernel.data.ColumnarBatch> read(io.delta.kernel.utils.FileStatus fileStatus, io.delta.kernel.types.StructType schema, Optional<io.delta.kernel.expressions.Predicate> predicate)