RecordReaderIterator — Scala Iterator over Hadoop RecordReader’s Values
RecordReaderIterator
is a Scala scala.collection.Iterator over the values of a Hadoop RecordReader.
RecordReaderIterator
is created when:
-
New OrcFileFormat and ParquetFileFormat are requested to build a data reader
-
HadoopFileLinesReader and
HadoopFileWholeTextReader
are requested for an value iterator -
Legacy
OrcFileFormat
is requested to build a data reader
When requested to close, RecordReaderIterator
simply requests the underlying RecordReader to close.
When requested to check whether or not there more internal rows, RecordReaderIterator
simply requests the underlying RecordReader for nextKeyValue
.
When requested for the next internal row, RecordReaderIterator
simply requests the underlying RecordReader for getCurrentValue
.