Modifier and Type | Field and Description |
---|---|
protected HiveShim |
HiveTableSource.hiveShim |
Constructor and Description |
---|
HiveContinuousPartitionFetcherContext(ObjectPath tablePath,
HiveShim hiveShim,
JobConfWrapper confWrapper,
List<String> partitionKeys,
DataType[] fieldTypes,
String[] fieldNames,
Configuration configuration,
String defaultPartitionName) |
HiveRowDataPartitionComputer(HiveShim hiveShim,
String defaultPartValue,
String[] columnNames,
DataType[] columnTypes,
String[] partitionColumns) |
Modifier and Type | Field and Description |
---|---|
protected HiveShim |
HivePartitionFetcherContextBase.hiveShim |
Constructor and Description |
---|
HiveMapredSplitReader(org.apache.hadoop.mapred.JobConf jobConf,
List<String> partitionKeys,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split,
HiveShim hiveShim) |
HivePartitionFetcherContextBase(ObjectPath tablePath,
HiveShim hiveShim,
JobConfWrapper confWrapper,
List<String> partitionKeys,
DataType[] fieldTypes,
String[] fieldNames,
Configuration configuration,
String defaultPartitionName) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
HivePartitionUtils.parsePartitionValues(Map<String,String> partitionSpecs,
String[] fieldNames,
DataType[] fieldTypes,
String defaultPartitionName,
HiveShim shim)
Parse partition string specs into object values.
|
static Object |
HivePartitionUtils.restorePartitionValueFromType(HiveShim shim,
String valStr,
LogicalType partitionType,
String defaultPartitionName) |
Constructor and Description |
---|
HiveWriterFactory(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) |
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 |
HiveShimV237
Shim for Hive version 2.3.7.
|
class |
HiveShimV238
Shim for Hive version 2.3.8.
|
class |
HiveShimV239
Shim for Hive version 2.3.9.
|
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.
|
class |
HiveShimV313
Shim for Hive version 3.1.3.
|
Modifier and Type | Method and Description |
---|---|
static HiveShim |
HiveShimLoader.loadHiveShim(String version) |
Constructor and Description |
---|
HiveMetastoreClientWrapper(HiveConf hiveConf,
HiveShim hiveShim) |
Constructor and Description |
---|
HiveFunctionDefinitionFactory(HiveShim hiveShim) |
Modifier and Type | Method and Description |
---|---|
static TableSchema |
HiveTableUtil.createTableSchema(HiveConf hiveConf,
org.apache.hadoop.hive.metastore.api.Table hiveTable,
HiveMetastoreClientWrapper client,
HiveShim hiveShim) |
static Map<String,CatalogColumnStatisticsDataBase> |
HiveStatsUtil.getCatalogPartitionColumnStats(HiveMetastoreClientWrapper client,
HiveShim hiveShim,
org.apache.hadoop.hive.metastore.api.Table hiveTable,
String partitionName,
List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionColsSchema,
String defaultPartitionName)
Get column statistic for partition columns.
|
static List<org.apache.hadoop.hive.metastore.api.FieldSchema> |
HiveTableUtil.getNonPartitionFields(HiveConf hiveConf,
org.apache.hadoop.hive.metastore.api.Table hiveTable,
HiveShim hiveShim) |
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<org.apache.hadoop.hive.ql.udf.generic.GenericUDAFResolver> funcWrapper,
boolean isUDAFBridgeRequired,
boolean isUDAFResolve2,
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 org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] |
HiveInspectors.getArgInspectors(HiveShim hiveShim,
HiveFunctionArguments arguments)
Get object inspector for each function argument.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static HiveShim |
HiveParserUtils.getSessionHiveShim() |
Constructor and Description |
---|
HiveParserDDLSemanticAnalyzer(HiveParserQueryState queryState,
HiveCatalog hiveCatalog,
CatalogManager catalogManager,
HiveParser hiveParser,
HiveShim hiveShim,
HiveParserContext context,
HiveParserDMLHelper dmlHelper,
org.apache.calcite.tools.FrameworkConfig frameworkConfig,
org.apache.calcite.plan.RelOptCluster cluster,
org.apache.flink.table.planner.calcite.FlinkContext flinkContext) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.