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

Class 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveTypeUtil.HivePrimitiveCategory INTERVAL are not available in older versions.

Method Summary

Modifier and Type	Method and Description
static DataType	toFlinkType(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector) Convert a Hive ObjectInspector to a Flink data type.
static 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(DataType dataType, boolean checkPrecision) Convert Flink DataType to Hive TypeInfo.
static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo	toHiveTypeInfo(LogicalType logicalType, boolean checkPrecision) Convert Flink LogicalType to Hive TypeInfo.

Methods inherited from class java.lang.Object

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

Method Detail

toHiveTypeInfo

public static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo toHiveTypeInfo(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.

Parameters:

dataType - a Flink DataType

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

Returns:

the corresponding Hive data type

toHiveTypeInfo

public static org.apache.hadoop.hive.serde2.typeinfo.TypeInfo toHiveTypeInfo(LogicalType logicalType,
                                                                             boolean checkPrecision)

Convert Flink LogicalType 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.

Parameters:

logicalType - a Flink LogicalType

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

Returns:

the corresponding Hive data type

toFlinkType

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

Convert a Hive ObjectInspector to a Flink data type.

Parameters:

inspector - a Hive inspector

Returns:

the corresponding Flink data type

toFlinkType

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

Convert Hive data type to a Flink data type.

Parameters:

hiveType - a Hive data type

Returns:

the corresponding Flink data type