Class RowParquetChunkReader


  • public class RowParquetChunkReader
    extends Object
    A Parquet file reader that reads only provided row groups.
    • Constructor Detail

      • RowParquetChunkReader

        public RowParquetChunkReader​(org.apache.parquet.io.InputFile file)
        Creates a new instance of RowParquetChunkReader. Since no chunks are provided it reads all row groups of given file.
        Parameters:
        file - a Parquet file
      • RowParquetChunkReader

        public RowParquetChunkReader​(org.apache.parquet.io.InputFile file,
                                     long start,
                                     long end)
        Creates a new instance of RowParquetChunkReader.
        Parameters:
        file - a Parquet file
        start - a starting row group position
        end - an ending row group position (exclusive)
      • RowParquetChunkReader

        public RowParquetChunkReader​(org.apache.parquet.io.InputFile file,
                                     List<ChunkInterval> chunks)
        Creates a new instance of RowParquetChunkReader.
        Parameters:
        file - a Parquet file
        chunks - a list of row group chunks
    • Method Detail

      • read

        public void read​(Consumer<Row> rowConsumer)
        Reads row group chunks of a Parquet file.
        Parameters:
        rowConsumer - a consumer function that accept read data