@Internal public class MetaDataReaderFunction extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
MetaDataReaderFunction(org.apache.flink.configuration.ReadableConfig config,
Schema tableSchema,
Schema projectedSchema,
FileIO io,
EncryptionManager encryption) |
Modifier and Type | Method and Description |
---|---|
DataIterator<org.apache.flink.table.data.RowData> |
createDataIterator(IcebergSourceSplit split) |
apply
public MetaDataReaderFunction(org.apache.flink.configuration.ReadableConfig config, Schema tableSchema, Schema projectedSchema, FileIO io, EncryptionManager encryption)
public DataIterator<org.apache.flink.table.data.RowData> createDataIterator(IcebergSourceSplit split)
createDataIterator
in class DataIteratorReaderFunction<org.apache.flink.table.data.RowData>