Package org.apache.iceberg.flink.source.reader

Class AvroGenericRecordReaderFunction

java.lang.Object

org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction<org.apache.avro.generic.GenericRecord>

org.apache.iceberg.flink.source.reader.AvroGenericRecordReaderFunction

All Implemented Interfaces:

java.io.Serializable, java.util.function.Function<IcebergSourceSplit,CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<org.apache.avro.generic.GenericRecord>>>>, ReaderFunction<org.apache.avro.generic.GenericRecord>

public class AvroGenericRecordReaderFunction
extends DataIteratorReaderFunction<org.apache.avro.generic.GenericRecord>

Read Iceberg rows as GenericRecord.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AvroGenericRecordReaderFunction(java.lang.String tableName, org.apache.flink.configuration.ReadableConfig config, Schema tableSchema, Schema projectedSchema, java.lang.String nameMapping, boolean caseSensitive, FileIO io, EncryptionManager encryption)

Method Summary

Modifier and Type	Method	Description
protected DataIterator<org.apache.avro.generic.GenericRecord>	createDataIterator(IcebergSourceSplit split)
static AvroGenericRecordReaderFunction	fromTable(Table table)	Create a reader function without projection and name mapping.

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

Constructor Detail

AvroGenericRecordReaderFunction

public AvroGenericRecordReaderFunction(java.lang.String tableName,
                                       org.apache.flink.configuration.ReadableConfig config,
                                       Schema tableSchema,
                                       Schema projectedSchema,
                                       java.lang.String nameMapping,
                                       boolean caseSensitive,
                                       FileIO io,
                                       EncryptionManager encryption)

Method Detail

fromTable

public static AvroGenericRecordReaderFunction fromTable(Table table)

Create a reader function without projection and name mapping. Column name is case-insensitive.

createDataIterator

protected DataIterator<org.apache.avro.generic.GenericRecord> createDataIterator(IcebergSourceSplit split)

Specified by:

createDataIterator in class DataIteratorReaderFunction<org.apache.avro.generic.GenericRecord>