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

Class HiveReflectionUtils

java.lang.Object

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

public class HiveReflectionUtils
extends Object

Utilities for accessing Hive class or methods via Java reflection.

They are put here not for code sharing. Rather, this is a boiler place for managing similar code that involves reflection. (In fact, they could be just private method in their respective calling class.)

Relevant Hive methods cannot be called directly because shimming is required to support different, possibly incompatible Hive versions.

Constructor Summary

Constructors

Constructor and Description
HiveReflectionUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector	createConstantObjectInspector(String className, Class<?> valueClz, Object value)
static List<String>	getPvals(HiveShim hiveShim, List<org.apache.hadoop.hive.metastore.api.FieldSchema> partCols, Map<String,String> partSpec)
static Properties	getTableMetadata(HiveShim hiveShim, org.apache.hadoop.hive.metastore.api.Table table)
static Object	invokeMethod(Class clz, Object obj, String methodName, Class[] argClz, Object[] args)
static Class	tryGetClass(String name)
static Method	tryGetMethod(Class clz, String name, Class[] argTypes)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveReflectionUtils

public HiveReflectionUtils()

Method Detail

getTableMetadata

public static Properties getTableMetadata(HiveShim hiveShim,
                                          org.apache.hadoop.hive.metastore.api.Table table)

getPvals

public static List<String> getPvals(HiveShim hiveShim,
                                    List<org.apache.hadoop.hive.metastore.api.FieldSchema> partCols,
                                    Map<String,String> partSpec)

createConstantObjectInspector

public static org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector createConstantObjectInspector(String className,
                                                                                                          Class<?> valueClz,
                                                                                                          Object value)

invokeMethod

public static Object invokeMethod(Class clz,
                                  Object obj,
                                  String methodName,
                                  Class[] argClz,
                                  Object[] args)
                           throws NoSuchMethodException,
                                  InvocationTargetException,
                                  IllegalAccessException

Throws:

NoSuchMethodException

InvocationTargetException

IllegalAccessException

tryGetClass

public static Class tryGetClass(String name)

tryGetMethod

public static Method tryGetMethod(Class clz,
                                  String name,
                                  Class[] argTypes)