org.apache.flink.table.functions.hive.conversion

Class HiveInspectors

java.lang.Object

org.apache.flink.table.functions.hive.conversion.HiveInspectors

@Internal
public class HiveInspectors
extends Object

Util for any ObjectInspector related inspection and conversion of Hive data to/from Flink data.

Hive ObjectInspector is a group of flexible APIs to inspect value in different data representation, and developers can extend those API as needed, so technically, object inspector supports arbitrary data type in java.

Constructor Summary

Constructors

Constructor and Description
HiveInspectors()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[]	getArgInspectors(HiveShim hiveShim, HiveFunctionArguments arguments) Get object inspector for each function argument.
static HiveObjectConversion	getConversion(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector, LogicalType dataType, HiveShim hiveShim) Get conversion for converting Flink object to Hive object from an ObjectInspector and the corresponding Flink DataType.
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	getObjectInspector(DataType flinkType) Get Hive ObjectInspector for a Flink DataType.
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	getObjectInspector(LogicalType flinkType) Get Hive ObjectInspector for a Flink LogicalType.
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	getObjectInspector(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo type)
static Object	toFlinkObject(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector, Object data, HiveShim hiveShim) Converts a Hive object to Flink object with an ObjectInspector.
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[]	toInspectors(HiveShim hiveShim, Object[] args, DataType[] argTypes) Get an array of ObjectInspector from the give array of args and their types.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveInspectors

public HiveInspectors()

Method Detail

getArgInspectors

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] getArgInspectors(HiveShim hiveShim,
                                                                                               HiveFunctionArguments arguments)

Get object inspector for each function argument.

toInspectors

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] toInspectors(HiveShim hiveShim,
                                                                                           Object[] args,
                                                                                           DataType[] argTypes)

Get an array of ObjectInspector from the give array of args and their types.

getConversion

public static HiveObjectConversion getConversion(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
                                                 LogicalType dataType,
                                                 HiveShim hiveShim)

Get conversion for converting Flink object to Hive object from an ObjectInspector and the corresponding Flink DataType.

toFlinkObject

public static Object toFlinkObject(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
                                   Object data,
                                   HiveShim hiveShim)

Converts a Hive object to Flink object with an ObjectInspector.

getObjectInspector

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector(DataType flinkType)

Get Hive ObjectInspector for a Flink DataType.

getObjectInspector

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector(LogicalType flinkType)

Get Hive ObjectInspector for a Flink LogicalType.

getObjectInspector

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector getObjectInspector(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo type)