org.apache.iceberg.flink.source.reader

Class RowDataReaderFunction

java.lang.Object

org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction<org.apache.flink.table.data.RowData>

org.apache.iceberg.flink.source.reader.RowDataReaderFunction

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>

public class RowDataReaderFunction
extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowDataReaderFunction(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)

Method Summary

Modifier and Type	Method and Description
DataIterator<org.apache.flink.table.data.RowData>	createDataIterator(IcebergSourceSplit split)

Methods inherited from class org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction

apply

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

RowDataReaderFunction

public RowDataReaderFunction(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)

Method Detail

createDataIterator

public DataIterator<org.apache.flink.table.data.RowData> createDataIterator(IcebergSourceSplit split)

Specified by:

createDataIterator in class DataIteratorReaderFunction<org.apache.flink.table.data.RowData>