org.apache.flink.formats.parquet.utils

Class ParquetSchemaConverter

java.lang.Object

org.apache.flink.formats.parquet.utils.ParquetSchemaConverter

public class ParquetSchemaConverter
extends Object

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

Constructor Summary

Constructors

Constructor and Description
ParquetSchemaConverter()

Method Summary

Modifier and Type	Method and Description
static int	computeMinBytesForDecimalPrecision(int precision)
static org.apache.parquet.schema.MessageType	convertToParquetMessageType(String name, RowType rowType)
static org.apache.parquet.schema.Type	convertToParquetType(String name, LogicalType type)
static boolean	is32BitDecimal(int precision)
static boolean	is64BitDecimal(int precision)

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(String name,
                                                                                RowType rowType)

convertToParquetType

public static org.apache.parquet.schema.Type convertToParquetType(String name,
                                                                  LogicalType type)

computeMinBytesForDecimalPrecision

public static int computeMinBytesForDecimalPrecision(int precision)

is32BitDecimal

public static boolean is32BitDecimal(int precision)

is64BitDecimal

public static boolean is64BitDecimal(int precision)