org.apache.iceberg.flink.source

Class RowDataToAvroGenericRecordConverter

java.lang.Object

org.apache.iceberg.flink.source.RowDataToAvroGenericRecordConverter

All Implemented Interfaces:

java.util.function.Function<org.apache.flink.table.data.RowData,org.apache.avro.generic.GenericRecord>

@Internal
public class RowDataToAvroGenericRecordConverter
extends java.lang.Object
implements java.util.function.Function<org.apache.flink.table.data.RowData,org.apache.avro.generic.GenericRecord>

This is not serializable because Avro Schema is not actually serializable, even though it implements Serializable interface.

Method Summary

Modifier and Type	Method and Description
org.apache.avro.generic.GenericRecord	apply(org.apache.flink.table.data.RowData rowData)
static RowDataToAvroGenericRecordConverter	fromAvroSchema(org.apache.avro.Schema avroSchema) Create a mapper based on Avro schema
static RowDataToAvroGenericRecordConverter	fromIcebergSchema(java.lang.String tableName, Schema icebergSchema) Create a converter based on Iceberg schema

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

Method Detail

apply

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

Specified by:

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

fromIcebergSchema

public static RowDataToAvroGenericRecordConverter fromIcebergSchema(java.lang.String tableName,
                                                                    Schema icebergSchema)

Create a converter based on Iceberg schema

fromAvroSchema

public static RowDataToAvroGenericRecordConverter fromAvroSchema(org.apache.avro.Schema avroSchema)

Create a mapper based on Avro schema