Constructor and Description |
---|
HiveOutputFormatFactory(org.apache.hadoop.mapred.JobConf jobConf,
Class hiveOutputFormatClz,
org.apache.hadoop.hive.metastore.api.SerDeInfo serDeInfo,
TableSchema schema,
String[] partitionColumns,
Properties tableProperties,
HiveShim hiveShim,
boolean isCompressed) |
Constructor and Description |
---|
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf,
List<String> partitionKeys,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split,
HiveShim hiveShim) |
Modifier and Type | Class and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static HiveShim |
HiveShimLoader.loadHiveShim(String version) |
Constructor and Description |
---|
HiveFunctionDefinitionFactory(HiveShim hiveShim) |
Modifier and Type | Method and Description |
---|---|
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<Expression> expressions,
HiveShim hiveShim)
Generates a filter string for partition columns from the given filter expressions.
|
Constructor and Description |
---|
DeferredObjectAdapter(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector inspector,
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) |
Modifier and Type | Method and Description |
---|---|
static HiveObjectConversion |
HiveInspectors.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 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,
DataType[] argTypes)
Get an array of ObjectInspector from the give array of args and their types.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.