public class HiveStatsUtil extends Object
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_STATS_ZERO_CONST |
Modifier and Type | Method and Description |
---|---|
static Map<String,CatalogColumnStatisticsDataBase> |
createCatalogColumnStats(List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> hiveColStats)
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)
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)
Create columnStatistics from the given Hive column stats of a hive table.
|
public static final String DEFAULT_STATS_ZERO_CONST
public static Map<String,CatalogColumnStatisticsDataBase> createCatalogColumnStats(@Nonnull List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> hiveColStats)
public static org.apache.hadoop.hive.metastore.api.ColumnStatistics createTableColumnStats(org.apache.hadoop.hive.metastore.api.Table hiveTable, Map<String,CatalogColumnStatisticsDataBase> colStats)
public static org.apache.hadoop.hive.metastore.api.ColumnStatistics createPartitionColumnStats(org.apache.hadoop.hive.metastore.api.Partition hivePartition, String partName, Map<String,CatalogColumnStatisticsDataBase> colStats)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.