org.apache.iceberg.flink.source

Class DataIterator<T>

java.lang.Object

org.apache.iceberg.flink.source.DataIterator<T>

Type Parameters:

T - is the output data type returned by this iterator.

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<T>, CloseableIterator<T>

@Internal
public class DataIterator<T>
extends java.lang.Object
implements CloseableIterator<T>

Flink data iterator that reads CombinedScanTask into a CloseableIterator

Constructor Summary

Constructors

Constructor and Description
DataIterator(FileScanTaskReader<T> fileScanTaskReader, CombinedScanTask task, FileIO io, EncryptionManager encryption)

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.io.CloseableIterator

empty, transform, withClose

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

DataIterator

public DataIterator(FileScanTaskReader<T> fileScanTaskReader,
                    CombinedScanTask task,
                    FileIO io,
                    EncryptionManager encryption)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<T>

next

public T next()

Specified by:

next in interface java.util.Iterator<T>

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException