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

Class AvroGenericRecordConverter

java.lang.Object

org.apache.iceberg.flink.source.reader.AvroGenericRecordConverter

All Implemented Interfaces:

Serializable, Function<org.apache.flink.table.data.RowData,org.apache.avro.generic.GenericRecord>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.avro.generic.GenericRecord>, RowDataConverter<org.apache.avro.generic.GenericRecord>

public class AvroGenericRecordConverter
extends Object
implements RowDataConverter<org.apache.avro.generic.GenericRecord>

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	apply(org.apache.flink.table.data.RowData rowData)
static AvroGenericRecordConverter	fromAvroSchema(org.apache.avro.Schema avroSchema, String tableName)
static AvroGenericRecordConverter	fromIcebergSchema(Schema icebergSchema, String tableName)
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord>	getProducedType()

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

Method Details

fromIcebergSchema

public static AvroGenericRecordConverter fromIcebergSchema(Schema icebergSchema,
 String tableName)

fromAvroSchema

public static AvroGenericRecordConverter fromAvroSchema(org.apache.avro.Schema avroSchema,
 String tableName)

apply

public org.apache.avro.generic.GenericRecord apply(org.apache.flink.table.data.RowData rowData)

Specified by:

apply in interface Function<org.apache.flink.table.data.RowData,org.apache.avro.generic.GenericRecord>

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.avro.generic.GenericRecord>