Package org.apache.iceberg.flink.formats.avro

Class AvroToRowDataConverters

java.lang.Object

org.apache.iceberg.flink.formats.avro.AvroToRowDataConverters

@Internal
public class AvroToRowDataConverters
extends Object

Tool class used to convert from Avro GenericRecord to RowData.

This class is adapted in Iceberg to add support for nanosecond precision timestamps (FLINK-39251). Once that ticket is resolved in Flink, this custom converter may be removed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AvroToRowDataConverters.AvroToRowDataConverter	Runtime converter that converts Avro data structures into objects of Flink Table & SQL internal data structures.

Method Summary

Modifier and Type	Method	Description
static AvroToRowDataConverters.AvroToRowDataConverter	createRowConverter(org.apache.flink.table.types.logical.RowType rowType)
static AvroToRowDataConverters.AvroToRowDataConverter	createRowConverter(org.apache.flink.table.types.logical.RowType rowType, boolean legacyTimestampMapping)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

createRowConverter

public static AvroToRowDataConverters.AvroToRowDataConverter createRowConverter(org.apache.flink.table.types.logical.RowType rowType)

createRowConverter

public static AvroToRowDataConverters.AvroToRowDataConverter createRowConverter(org.apache.flink.table.types.logical.RowType rowType,
 boolean legacyTimestampMapping)