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

Class RowDataToAvroConverters

java.lang.Object

org.apache.iceberg.flink.formats.avro.RowDataToAvroConverters

@Internal
public class RowDataToAvroConverters
extends Object

Tool class used to convert from RowData to Avro GenericRecord.

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	RowDataToAvroConverters.RowDataToAvroConverter	Runtime converter that converts objects of Flink Table & SQL internal data structures to corresponding Avro data structures.

Method Summary

Modifier and Type	Method	Description
static RowDataToAvroConverters.RowDataToAvroConverter	createConverter(org.apache.flink.table.types.logical.LogicalType type)	Creates a runtime converter according to the given logical type that converts objects of Flink Table & SQL internal data structures to corresponding Avro data structures.
static RowDataToAvroConverters.RowDataToAvroConverter	createConverter(org.apache.flink.table.types.logical.LogicalType type, boolean legacyTimestampMapping)

Methods inherited from class java.lang.Object

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

Method Details

createConverter

public static RowDataToAvroConverters.RowDataToAvroConverter createConverter(org.apache.flink.table.types.logical.LogicalType type)

Creates a runtime converter according to the given logical type that converts objects of Flink Table & SQL internal data structures to corresponding Avro data structures.

createConverter

public static RowDataToAvroConverters.RowDataToAvroConverter createConverter(org.apache.flink.table.types.logical.LogicalType type,
 boolean legacyTimestampMapping)