org.apache.paimon.format.avro

Class AvroSchemaConverter

java.lang.Object

org.apache.paimon.format.avro.AvroSchemaConverter

public class AvroSchemaConverter
extends Object

Converts an Avro schema into Paimon's type information.

Method Summary

Modifier and Type	Method and Description
static org.apache.avro.Schema	convertToSchema(DataType schema, Map<String,String> rowNameMapping) Converts Paimon DataType (can be nested) into an Avro schema.
static org.apache.avro.Schema	convertToSchema(DataType dataType, String rowName, Map<String,String> rowNameMapping) Converts Paimon DataType (can be nested) into an Avro schema.
static DataType	extractKeyTypeToAvroMap(DataType type)
static DataType	extractValueTypeToAvroMap(DataType type)
static boolean	isArrayMap(DataType type)

Methods inherited from class java.lang.Object

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

Method Detail

convertToSchema

public static org.apache.avro.Schema convertToSchema(DataType schema,
                                                     Map<String,String> rowNameMapping)

Converts Paimon DataType (can be nested) into an Avro schema.

Use "org.apache.paimon.avro.generated.record" as the type name.

Parameters:

schema - the schema type, usually it should be the top level record type, e.g. not a nested type

Returns:

Avro's Schema matching this logical type.

convertToSchema

public static org.apache.avro.Schema convertToSchema(DataType dataType,
                                                     String rowName,
                                                     Map<String,String> rowNameMapping)

Converts Paimon DataType (can be nested) into an Avro schema.

The "{rowName}_" is used as the nested row type name prefix in order to generate the right schema. Nested record type that only differs with type name is still compatible.

Parameters:

dataType - logical type

rowName - the record name

Returns:

Avro's Schema matching this logical type.

isArrayMap

public static boolean isArrayMap(DataType type)

extractKeyTypeToAvroMap

public static DataType extractKeyTypeToAvroMap(DataType type)

extractValueTypeToAvroMap

public static DataType extractValueTypeToAvroMap(DataType type)