Package com.exasol.parquetio.reader
Class RowParquetChunkReader
- java.lang.Object
-
- com.exasol.parquetio.reader.RowParquetChunkReader
-
public class RowParquetChunkReader extends Object
A Parquet file reader that reads only provided row groups.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static classRowParquetChunkReader.RecordIteratorIterator that reads the rows of a row group.static classRowParquetChunkReader.RowIteratorIterator that reads the rows of a given list of chunks.
-
Constructor Summary
Constructors Constructor Description RowParquetChunkReader(org.apache.parquet.io.InputFile file)Creates a new instance ofRowParquetChunkReader.RowParquetChunkReader(org.apache.parquet.io.InputFile file, long start, long end)Creates a new instance ofRowParquetChunkReader.RowParquetChunkReader(org.apache.parquet.io.InputFile file, List<ChunkInterval> chunks)Creates a new instance ofRowParquetChunkReader.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RowParquetChunkReader.RowIteratoriterator()Get an iterator that reads the rows.voidread(Consumer<Row> rowConsumer)Reads row group chunks of a Parquet file.
-
-
-
Constructor Detail
-
RowParquetChunkReader
public RowParquetChunkReader(org.apache.parquet.io.InputFile file)
Creates a new instance ofRowParquetChunkReader. 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 ofRowParquetChunkReader.- Parameters:
file- a Parquet filestart- a starting row group positionend- an ending row group position (exclusive)
-
RowParquetChunkReader
public RowParquetChunkReader(org.apache.parquet.io.InputFile file, List<ChunkInterval> chunks)Creates a new instance ofRowParquetChunkReader.- Parameters:
file- a Parquet filechunks- a list of row group chunks
-
-
Method Detail
-
iterator
public RowParquetChunkReader.RowIterator iterator()
Get an iterator that reads the rows.- Returns:
- iterator
-
-