接口的使用
org.apache.flink.table.catalog.hive.client.HiveShim

使用HiveShim的程序包

程序包	说明
org.apache.flink.connectors.hive
org.apache.flink.connectors.hive.read
org.apache.flink.table.catalog.hive.client
org.apache.flink.table.catalog.hive.factories
org.apache.flink.table.catalog.hive.util
org.apache.flink.table.functions.hive
org.apache.flink.table.functions.hive.conversion

org.apache.flink.connectors.hive中HiveShim的使用

参数类型为HiveShim的org.apache.flink.connectors.hive中的构造器

构造器和说明
HiveOutputFormatFactory(org.apache.hadoop.mapred.JobConf jobConf, Class hiveOutputFormatClz, org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo, org.apache.flink.table.api.TableSchema schema, String[] partitionColumns, Properties tableProperties, HiveShim hiveShim, boolean isCompressed)

org.apache.flink.connectors.hive.read中HiveShim的使用

参数类型为HiveShim的org.apache.flink.connectors.hive.read中的构造器

构造器和说明
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf, List<String> partitionKeys, org.apache.flink.table.types.DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split, HiveShim hiveShim)

org.apache.flink.table.catalog.hive.client中HiveShim的使用

实现HiveShim的org.apache.flink.table.catalog.hive.client中的类

限定符和类型	类和说明
class	HiveShimV100 Shim for Hive version 1.0.0.
class	HiveShimV101 Shim for Hive version 1.0.1.
class	HiveShimV110 Shim for Hive version 1.1.0.
class	HiveShimV111 Shim for Hive version 1.1.1.
class	HiveShimV120 Shim for Hive version 1.2.0.
class	HiveShimV121 Shim for Hive version 1.2.1.
class	HiveShimV122 Shim for Hive version 1.2.2.
class	HiveShimV200 Shim for Hive version 2.0.0.
class	HiveShimV201 Shim for Hive version 2.0.1.
class	HiveShimV210 Shim for Hive version 2.1.0.
class	HiveShimV211 Shim for Hive version 2.1.1.
class	HiveShimV220 Shim for Hive version 2.2.0.
class	HiveShimV230 Shim for Hive version 2.3.0.
class	HiveShimV231 Shim for Hive version 2.3.1.
class	HiveShimV232 Shim for Hive version 2.3.2.
class	HiveShimV233 Shim for Hive version 2.3.3.
class	HiveShimV234 Shim for Hive version 2.3.4.
class	HiveShimV235 Shim for Hive version 2.3.5.
class	HiveShimV236 Shim for Hive version 2.3.6.
class	HiveShimV310 Shim for Hive version 3.1.0.
class	HiveShimV311 Shim for Hive version 3.1.1.
class	HiveShimV312 Shim for Hive version 3.1.2.

返回HiveShim的org.apache.flink.table.catalog.hive.client中的方法

限定符和类型	方法和说明
static HiveShim	HiveShimLoader.loadHiveShim(String version)

org.apache.flink.table.catalog.hive.factories中HiveShim的使用

参数类型为HiveShim的org.apache.flink.table.catalog.hive.factories中的构造器

构造器和说明
HiveFunctionDefinitionFactory(HiveShim hiveShim)

org.apache.flink.table.catalog.hive.util中HiveShim的使用

参数类型为HiveShim的org.apache.flink.table.catalog.hive.util中的方法

限定符和类型	方法和说明
static List<String>	HiveReflectionUtils.getPvals(HiveShim hiveShim, List<org.apache.hadoop.hive.metastore.api.FieldSchema> partCols, Map<String,String> partSpec)
static Properties	HiveReflectionUtils.getTableMetadata(HiveShim hiveShim, org.apache.hadoop.hive.metastore.api.Table table)
static Optional<String>	HiveTableUtil.makePartitionFilter(int partColOffset, List<String> partColNames, List<org.apache.flink.table.expressions.Expression> expressions, HiveShim hiveShim) Generates a filter string for partition columns from the given filter expressions.

org.apache.flink.table.functions.hive中HiveShim的使用

参数类型为HiveShim的org.apache.flink.table.functions.hive中的构造器

构造器和说明
DeferredObjectAdapter(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector, org.apache.flink.table.types.logical.LogicalType logicalType, HiveShim hiveShim)
HiveGenericUDAF(HiveFunctionWrapper funcWrapper, boolean isUDAFBridgeRequired, HiveShim hiveShim)
HiveGenericUDAF(HiveFunctionWrapper funcWrapper, HiveShim hiveShim)
HiveGenericUDF(HiveFunctionWrapper<org.apache.hadoop.hive.ql.udf.generic.GenericUDF> hiveFunctionWrapper, HiveShim hiveShim)
HiveGenericUDTF(HiveFunctionWrapper<org.apache.hadoop.hive.ql.udf.generic.GenericUDTF> hiveFunctionWrapper, HiveShim hiveShim)
HiveSimpleUDF(HiveFunctionWrapper<org.apache.hadoop.hive.ql.exec.UDF> hiveFunctionWrapper, HiveShim hiveShim)

org.apache.flink.table.functions.hive.conversion中HiveShim的使用

参数类型为HiveShim的org.apache.flink.table.functions.hive.conversion中的方法

限定符和类型	方法和说明
static HiveObjectConversion	HiveInspectors.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 Object	HiveInspectors.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[]	HiveInspectors.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.