Package org.apache.iceberg.flink.source

Interface FileScanTaskReader<T>

Type Parameters:

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

All Superinterfaces:

Serializable

All Known Implementing Classes:

AvroGenericRecordFileScanTaskReader, DataTaskReader, RowDataFileScanTaskReader

@Internal
public interface FileScanTaskReader<T>
extends Serializable

Read a FileScanTask into a CloseableIterator

Method Summary

Modifier and Type	Method	Description
CloseableIterator<T>	open(FileScanTask fileScanTask, InputFilesDecryptor inputFilesDecryptor)

Method Details

open

CloseableIterator<T> open(FileScanTask fileScanTask,
 InputFilesDecryptor inputFilesDecryptor)