@Internal public class DataTaskReader extends java.lang.Object implements FileScanTaskReader<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
DataTaskReader(Schema readSchema) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<org.apache.flink.table.data.RowData> |
open(FileScanTask task,
InputFilesDecryptor inputFilesDecryptor) |
public DataTaskReader(Schema readSchema)
public CloseableIterator<org.apache.flink.table.data.RowData> open(FileScanTask task, InputFilesDecryptor inputFilesDecryptor)
open
in interface FileScanTaskReader<org.apache.flink.table.data.RowData>