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 asGenericRecord
.- 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
All Methods Static Methods Instance Methods Concrete Methods 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
-
-
-
-
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 classDataIteratorReaderFunction<org.apache.avro.generic.GenericRecord>
-
-