Package org.apache.iceberg.flink.source
Interface FileScanTaskReader<T>
-
- Type Parameters:
T
- is the output data type returned by this iterator.
- All Superinterfaces:
java.io.Serializable
- All Known Implementing Classes:
AvroGenericRecordFileScanTaskReader
,DataTaskReader
,RowDataFileScanTaskReader
@Internal public interface FileScanTaskReader<T> extends java.io.Serializable
Read aFileScanTask
into aCloseableIterator
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CloseableIterator<T>
open(FileScanTask fileScanTask, InputFilesDecryptor inputFilesDecryptor)
-
-
-
Method Detail
-
open
CloseableIterator<T> open(FileScanTask fileScanTask, InputFilesDecryptor inputFilesDecryptor)
-
-