@Internal
public class RowDataToAvroGenericRecordConverter
extends java.lang.Object
implements java.util.function.Function<org.apache.flink.table.data.RowData,org.apache.avro.generic.GenericRecord>
Schema
is not actually serializable, even though it
implements Serializable
interface.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
|
public org.apache.avro.generic.GenericRecord apply(org.apache.flink.table.data.RowData rowData)
apply
in interface java.util.function.Function<org.apache.flink.table.data.RowData,org.apache.avro.generic.GenericRecord>
public static RowDataToAvroGenericRecordConverter fromIcebergSchema(java.lang.String tableName, Schema icebergSchema)
public static RowDataToAvroGenericRecordConverter fromAvroSchema(org.apache.avro.Schema avroSchema)