public class HivePartitionUtils extends Object
Constructor and Description |
---|
HivePartitionUtils() |
Modifier and Type | Method and Description |
---|---|
static List<HiveTablePartition> |
getAllPartitions(org.apache.hadoop.mapred.JobConf jobConf,
String hiveVersion,
ObjectPath tablePath,
CatalogTable catalogTable,
HiveShim hiveShim,
List<Map<String,String>> remainingPartitions)
Returns all HiveTablePartitions of a hive table, returns single HiveTablePartition if the
hive table is not partitioned.
|
static org.apache.hadoop.fs.FileStatus[] |
getFileStatusRecurse(org.apache.hadoop.fs.Path path,
int expectLevel,
org.apache.hadoop.fs.FileSystem fs) |
static List<String> |
partitionSpecToValues(Map<String,String> spec,
List<String> partitionColNames) |
static Object |
restorePartitionValueFromType(HiveShim shim,
String valStr,
DataType type) |
static HiveTablePartition |
toHiveTablePartition(List<String> partitionKeys,
String[] fieldNames,
DataType[] fieldTypes,
HiveShim shim,
Properties tableProps,
String defaultPartitionName,
org.apache.hadoop.hive.metastore.api.Partition partition) |
public static Object restorePartitionValueFromType(HiveShim shim, String valStr, DataType type)
public static List<HiveTablePartition> getAllPartitions(org.apache.hadoop.mapred.JobConf jobConf, String hiveVersion, ObjectPath tablePath, CatalogTable catalogTable, HiveShim hiveShim, List<Map<String,String>> remainingPartitions)
public static List<String> partitionSpecToValues(Map<String,String> spec, List<String> partitionColNames)
public static HiveTablePartition toHiveTablePartition(List<String> partitionKeys, String[] fieldNames, DataType[] fieldTypes, HiveShim shim, Properties tableProps, String defaultPartitionName, org.apache.hadoop.hive.metastore.api.Partition partition)
public static org.apache.hadoop.fs.FileStatus[] getFileStatusRecurse(org.apache.hadoop.fs.Path path, int expectLevel, org.apache.hadoop.fs.FileSystem fs)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.