org.apache.paimon.format.parquet

Class ParquetSchemaConverter

java.lang.Object

org.apache.paimon.format.parquet.ParquetSchemaConverter

public class ParquetSchemaConverter
extends Object

Schema converter converts Parquet schema to and from Paimon internal types.

Constructor Summary

Constructors

Constructor and Description
ParquetSchemaConverter()

Method Summary

Modifier and Type	Method and Description
static int	computeMinBytesForDecimalPrecision(int precision)
static DataField	convertToPaimonField(org.apache.parquet.schema.Type parquetType) Convert parquet Type to paimon DataField to.
static RowType	convertToPaimonRowType(org.apache.parquet.schema.MessageType messageType) Convert parquet MessageType to paimon RowType.
static org.apache.parquet.schema.MessageType	convertToParquetMessageType(RowType rowType) Convert paimon RowType to parquet MessageType.
static org.apache.parquet.schema.Type	convertToParquetType(DataField field) Convert paimon DataField to parquet Type.
static boolean	is32BitDecimal(int precision)
static boolean	is64BitDecimal(int precision)
static org.apache.parquet.schema.Type	parquetListElementType(org.apache.parquet.schema.GroupType listType)
static Pair<org.apache.parquet.schema.Type,org.apache.parquet.schema.Type>	parquetMapKeyValueType(org.apache.parquet.schema.GroupType mapType)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetSchemaConverter

public ParquetSchemaConverter()

Method Detail

convertToParquetMessageType

public static org.apache.parquet.schema.MessageType convertToParquetMessageType(RowType rowType)

Convert paimon RowType to parquet MessageType.

convertToParquetType

public static org.apache.parquet.schema.Type convertToParquetType(DataField field)

Convert paimon DataField to parquet Type.

computeMinBytesForDecimalPrecision

public static int computeMinBytesForDecimalPrecision(int precision)

is32BitDecimal

public static boolean is32BitDecimal(int precision)

is64BitDecimal

public static boolean is64BitDecimal(int precision)

convertToPaimonRowType

public static RowType convertToPaimonRowType(org.apache.parquet.schema.MessageType messageType)

Convert parquet MessageType to paimon RowType.

convertToPaimonField

public static DataField convertToPaimonField(org.apache.parquet.schema.Type parquetType)

Convert parquet Type to paimon DataField to.

parquetListElementType

public static org.apache.parquet.schema.Type parquetListElementType(org.apache.parquet.schema.GroupType listType)

parquetMapKeyValueType

public static Pair<org.apache.parquet.schema.Type,org.apache.parquet.schema.Type> parquetMapKeyValueType(org.apache.parquet.schema.GroupType mapType)