Package com.exasol.parquetio.reader

Class RowParquetChunkReader.RowIterator

java.lang.Object

com.exasol.parquetio.reader.RowParquetChunkReader.RowIterator

All Implemented Interfaces:

AutoCloseable, Iterator<Row>

Enclosing class:

RowParquetChunkReader

public static class RowParquetChunkReader.RowIterator
extends Object
implements Iterator<Row>, AutoCloseable

Iterator that reads the rows of a given list of chunks.

Constructor Summary

Constructors

Constructor	Description
RowIterator(com.exasol.parquetio.reader.RowParquetChunkReader.PositionAwareReader reader, org.apache.parquet.io.InputFile file, org.apache.parquet.io.MessageColumnIO messageIO, org.apache.parquet.io.api.RecordMaterializer<Row> recordMaterializer, List<ChunkInterval> chunks)	Create a new instance of RowParquetChunkReader.RowIterator.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
Row	next()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

RowIterator

public RowIterator(com.exasol.parquetio.reader.RowParquetChunkReader.PositionAwareReader reader,
                   org.apache.parquet.io.InputFile file,
                   org.apache.parquet.io.MessageColumnIO messageIO,
                   org.apache.parquet.io.api.RecordMaterializer<Row> recordMaterializer,
                   List<ChunkInterval> chunks)

Create a new instance of RowParquetChunkReader.RowIterator.

Parameters:

reader - reader

file - file

messageIO - message io

recordMaterializer - record materializer

chunks - chunks to read

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Row>

next

public Row next()

Specified by:

next in interface Iterator<Row>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException