@Internal public class RowDataFileScanTaskReader extends java.lang.Object implements FileScanTaskReader<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
RowDataFileScanTaskReader(Schema tableSchema,
Schema projectedSchema,
java.lang.String nameMapping,
boolean caseSensitive,
java.util.List<Expression> filters) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<org.apache.flink.table.data.RowData> |
open(FileScanTask task,
InputFilesDecryptor inputFilesDecryptor) |
public RowDataFileScanTaskReader(Schema tableSchema, Schema projectedSchema, java.lang.String nameMapping, boolean caseSensitive, java.util.List<Expression> filters)
public CloseableIterator<org.apache.flink.table.data.RowData> open(FileScanTask task, InputFilesDecryptor inputFilesDecryptor)
open
in interface FileScanTaskReader<org.apache.flink.table.data.RowData>