public class AggregateStatsCache extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AggregateStatsCache.AggrColStats |
Modifier and Type | Method and Description |
---|---|
void |
add(String catName,
String dbName,
String tblName,
String colName,
long numPartsCached,
ColumnStatisticsObj colStats,
org.apache.hive.common.util.BloomFilter bloomFilter)
Add a new node to the cache; may trigger the cleaner thread if the cache is near full capacity.
|
AggregateStatsCache.AggrColStats |
get(String catName,
String dbName,
String tblName,
String colName,
List<String> partNames)
Return aggregate stats for a column from the cache or null.
|
int |
getCurrentNodes() |
double |
getFalsePositiveProbability() |
float |
getFullPercent() |
Float |
getHitRatio() |
static AggregateStatsCache |
getInstance(org.apache.hadoop.conf.Configuration conf) |
int |
getMaxCacheNodes() |
int |
getMaxPartsPerCacheNode() |
public static AggregateStatsCache getInstance(org.apache.hadoop.conf.Configuration conf)
public int getMaxCacheNodes()
public int getCurrentNodes()
public float getFullPercent()
public int getMaxPartsPerCacheNode()
public double getFalsePositiveProbability()
public Float getHitRatio()
public AggregateStatsCache.AggrColStats get(String catName, String dbName, String tblName, String colName, List<String> partNames)
catName
- catalog namedbName
- database nametblName
- table namecolName
- column namepartNames
- list of partition namespublic void add(String catName, String dbName, String tblName, String colName, long numPartsCached, ColumnStatisticsObj colStats, org.apache.hive.common.util.BloomFilter bloomFilter)
catName
- catalog namedbName
- database nametblName
- table namecolName
- column namenumPartsCached
- colStats
- bloomFilter
- Copyright © 2022 The Apache Software Foundation. All rights reserved.