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

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

构造器概要

构造器

构造器和说明
HiveInspectors()

方法概要

限定符和类型	方法和说明
static HiveObjectConversion	getConversion(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector, org.apache.flink.table.types.logical.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(org.apache.flink.table.types.DataType flinkType) Get Hive ObjectInspector for a Flink DataType.
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, org.apache.flink.table.types.DataType[] argTypes) Get an array of ObjectInspector from the give array of args and their types.

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

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

构造器详细资料

HiveInspectors

public HiveInspectors()

方法详细资料

toInspectors

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] toInspectors(HiveShim hiveShim,
                                                                                           Object[] args,
                                                                                           org.apache.flink.table.types.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,
                                                 org.apache.flink.table.types.logical.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(org.apache.flink.table.types.DataType flinkType)

Get Hive ObjectInspector for a Flink DataType.