Class MetaDataReaderFunction
- java.lang.Object
-
- org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction<org.apache.flink.table.data.RowData>
-
- org.apache.iceberg.flink.source.reader.MetaDataReaderFunction
-
- All Implemented Interfaces:
java.io.Serializable
,java.util.function.Function<IcebergSourceSplit,CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<org.apache.flink.table.data.RowData>>>>
,ReaderFunction<org.apache.flink.table.data.RowData>
@Internal public class MetaDataReaderFunction extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData>
Reading metadata tables (like snapshots, manifests, etc.)- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MetaDataReaderFunction(org.apache.flink.configuration.ReadableConfig config, Schema tableSchema, Schema projectedSchema, FileIO io, EncryptionManager encryption)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DataIterator<org.apache.flink.table.data.RowData>
createDataIterator(IcebergSourceSplit split)
-
Methods inherited from class org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction
apply
-
-
-
-
Constructor Detail
-
MetaDataReaderFunction
public MetaDataReaderFunction(org.apache.flink.configuration.ReadableConfig config, Schema tableSchema, Schema projectedSchema, FileIO io, EncryptionManager encryption)
-
-
Method Detail
-
createDataIterator
public DataIterator<org.apache.flink.table.data.RowData> createDataIterator(IcebergSourceSplit split)
- Specified by:
createDataIterator
in classDataIteratorReaderFunction<org.apache.flink.table.data.RowData>
-
-