org.apache.flink.table.catalog.hive.util

类 HiveTypeUtil

java.lang.Object

org.apache.flink.table.catalog.hive.util.HiveTypeUtil

@Internal
public class HiveTypeUtil
extends Object

Utils to convert data types between Flink and Hive.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	HiveTypeUtil.HivePrimitiveCategory INTERVAL are not available in older versions.

方法概要

限定符和类型	方法和说明
static org.apache.flink.table.types.DataType	toFlinkType(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector) Convert a Hive ObjectInspector to a Flink data type.
static org.apache.flink.table.types.DataType	toFlinkType(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo hiveType) Convert Hive data type to a Flink data type.
static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo	toHiveTypeInfo(org.apache.flink.table.types.DataType dataType, boolean checkPrecision) Convert Flink DataType to Hive TypeInfo.

从类继承的方法 java.lang.Object

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

方法详细资料

toHiveTypeInfo

public static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo toHiveTypeInfo(org.apache.flink.table.types.DataType dataType,
                                                                             boolean checkPrecision)

Convert Flink DataType to Hive TypeInfo. For types with a precision parameter, e.g. timestamp, the supported precisions in Hive and Flink can be different. Therefore the conversion will fail for those types if the precision is not supported by Hive and checkPrecision is true.

参数:

dataType - a Flink DataType

checkPrecision - whether to fail the conversion if the precision of the DataType is not supported by Hive

返回:

the corresponding Hive data type

toFlinkType

public static org.apache.flink.table.types.DataType toFlinkType(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector)

Convert a Hive ObjectInspector to a Flink data type.

参数:

inspector - a Hive inspector

返回:

the corresponding Flink data type

toFlinkType

public static org.apache.flink.table.types.DataType toFlinkType(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo hiveType)

Convert Hive data type to a Flink data type.

参数:

hiveType - a Hive data type

返回:

the corresponding Flink data type