Package org.apache.iceberg.orc

Class VectorizedRowBatchIterator

java.lang.Object

org.apache.iceberg.orc.VectorizedRowBatchIterator

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long>>, CloseableIterator<Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long>>

public class VectorizedRowBatchIterator
extends Object
implements CloseableIterator<Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long>>

An adaptor so that the ORC RecordReader can be used as an Iterator. Because the same VectorizedRowBatch is reused on each call to next, it gets changed when hasNext or next is called.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long>	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

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long>>

next

public Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long> next()

Specified by:

next in interface Iterator<Pair<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,Long>>