Class ConverterReaderFunction<T>
- java.lang.Object
-
- org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction<T>
-
- org.apache.iceberg.flink.source.reader.ConverterReaderFunction<T>
-
- All Implemented Interfaces:
java.io.Serializable
,java.util.function.Function<IcebergSourceSplit,CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>>>
,ReaderFunction<T>
@Internal public class ConverterReaderFunction<T> extends DataIteratorReaderFunction<T>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ConverterReaderFunction(RowDataConverter<T> converter, org.apache.flink.configuration.ReadableConfig config, Schema tableSchema, Schema projectedSchema, java.lang.String nameMapping, boolean caseSensitive, FileIO io, EncryptionManager encryption, java.util.List<Expression> filters, long limit)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected DataIterator<T>
createDataIterator(IcebergSourceSplit split)
-
Methods inherited from class org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction
apply
-
-
-
-
Constructor Detail
-
ConverterReaderFunction
public ConverterReaderFunction(RowDataConverter<T> converter, org.apache.flink.configuration.ReadableConfig config, Schema tableSchema, Schema projectedSchema, java.lang.String nameMapping, boolean caseSensitive, FileIO io, EncryptionManager encryption, java.util.List<Expression> filters, long limit)
-
-
Method Detail
-
createDataIterator
protected DataIterator<T> createDataIterator(IcebergSourceSplit split)
- Specified by:
createDataIterator
in classDataIteratorReaderFunction<T>
-
-