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 a FileScanTask into a CloseableIterator

Method Summary

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

Method Detail

open

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