public class HiveStatsUtil extends Object
Modifier and Type | Method and Description |
---|---|
static Map<String,CatalogColumnStatisticsDataBase> |
createCatalogColumnStats(List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> hiveColStats,
String hiveVersion)
Create a map of Flink column stats from the given Hive column stats.
|
static org.apache.hadoop.hive.metastore.api.ColumnStatistics |
createPartitionColumnStats(org.apache.hadoop.hive.metastore.api.Partition hivePartition,
String partName,
Map<String,CatalogColumnStatisticsDataBase> colStats,
String hiveVersion)
Create columnStatistics from the given Hive column stats of a hive partition.
|
static org.apache.hadoop.hive.metastore.api.ColumnStatistics |
createTableColumnStats(org.apache.hadoop.hive.metastore.api.Table hiveTable,
Map<String,CatalogColumnStatisticsDataBase> colStats,
String hiveVersion)
Create columnStatistics from the given Hive column stats of a hive table.
|
static int |
parsePositiveIntStat(Map<String,String> parameters,
String key) |
static long |
parsePositiveLongStat(Map<String,String> parameters,
String key) |
public static Map<String,CatalogColumnStatisticsDataBase> createCatalogColumnStats(@Nonnull List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> hiveColStats, String hiveVersion)
public static org.apache.hadoop.hive.metastore.api.ColumnStatistics createTableColumnStats(org.apache.hadoop.hive.metastore.api.Table hiveTable, Map<String,CatalogColumnStatisticsDataBase> colStats, String hiveVersion)
public static org.apache.hadoop.hive.metastore.api.ColumnStatistics createPartitionColumnStats(org.apache.hadoop.hive.metastore.api.Partition hivePartition, String partName, Map<String,CatalogColumnStatisticsDataBase> colStats, String hiveVersion)
public static int parsePositiveIntStat(Map<String,String> parameters, String key)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.