public class SharedCache extends Object
Constructor and Description |
---|
SharedCache() |
public void initialize(long maxSharedCacheSizeInBytes)
public void populateCatalogsInCache(Collection<Catalog> catalogs)
public void addCatalogToCache(Catalog cat)
public void removeCatalogFromCache(String name)
public boolean isCatalogCachePrewarmed()
public boolean isDatabaseCachePrewarmed()
public void addDatabaseToCache(Database db)
public void alterDatabaseInCache(String catName, String dbName, Database newDb)
public int getCachedDatabaseCount()
public boolean populateTableInCache(Table table, ColumnStatistics tableColStats, List<Partition> partitions, List<ColumnStatistics> partitionColStats, AggrStats aggrStatsAllPartitions, AggrStats aggrStatsAllButDefaultPartition)
public void completeTableCachePrewarm()
public org.apache.hadoop.hive.metastore.cache.SharedCache.TableWrapper addTableToCache(String catName, String dbName, String tblName, Table tbl)
public void removeTableFromCache(String catName, String dbName, String tblName)
public void alterTableInCache(String catName, String dbName, String tblName, Table newTable)
public List<String> listCachedTableNames(String catName, String dbName, String pattern, short maxTables)
public List<String> listCachedTableNames(String catName, String dbName, String pattern, TableType tableType)
public void refreshTablesInCache(String catName, String dbName, List<Table> tables)
public List<ColumnStatisticsObj> getTableColStatsFromCache(String catName, String dbName, String tblName, List<String> colNames)
public void removeTableColStatsFromCache(String catName, String dbName, String tblName, String colName)
public void updateTableColStatsInCache(String catName, String dbName, String tableName, List<ColumnStatisticsObj> colStatsForTable)
public void refreshTableColStatsInCache(String catName, String dbName, String tableName, List<ColumnStatisticsObj> colStatsForTable)
public int getCachedTableCount()
public List<TableMeta> getTableMeta(String catName, String dbNames, String tableNames, List<String> tableTypes)
public void addPartitionToCache(String catName, String dbName, String tblName, Partition part)
public void addPartitionsToCache(String catName, String dbName, String tblName, List<Partition> parts)
public Partition getPartitionFromCache(String catName, String dbName, String tblName, List<String> partVals)
public boolean existPartitionFromCache(String catName, String dbName, String tblName, List<String> partVals)
public Partition removePartitionFromCache(String catName, String dbName, String tblName, List<String> partVals)
public void removePartitionsFromCache(String catName, String dbName, String tblName, List<List<String>> partVals)
public List<Partition> listCachedPartitions(String catName, String dbName, String tblName, int max)
public void alterPartitionInCache(String catName, String dbName, String tblName, List<String> partVals, Partition newPart)
public void alterPartitionsInCache(String catName, String dbName, String tblName, List<List<String>> partValsList, List<Partition> newParts)
public void refreshPartitionsInCache(String catName, String dbName, String tblName, List<Partition> partitions)
public void removePartitionColStatsFromCache(String catName, String dbName, String tblName, List<String> partVals, String colName)
public void updatePartitionColStatsInCache(String catName, String dbName, String tableName, List<String> partVals, List<ColumnStatisticsObj> colStatsObjs)
public ColumnStatisticsObj getPartitionColStatsFromCache(String catName, String dbName, String tblName, List<String> partVal, String colName)
public void refreshPartitionColStatsInCache(String catName, String dbName, String tblName, List<ColumnStatistics> partitionColStats)
public List<ColumnStatisticsObj> getAggrStatsFromCache(String catName, String dbName, String tblName, List<String> colNames, org.apache.hadoop.hive.metastore.cache.SharedCache.StatsType statsType)
public void addAggregateStatsToCache(String catName, String dbName, String tblName, AggrStats aggrStatsAllPartitions, AggrStats aggrStatsAllButDefaultPartition)
public void refreshAggregateStatsInCache(String catName, String dbName, String tblName, AggrStats aggrStatsAllPartitions, AggrStats aggrStatsAllButDefaultPartition)
public void increSd(StorageDescriptor sd, byte[] sdHash)
public void decrSd(byte[] sdHash)
public StorageDescriptor getSdFromCache(byte[] sdHash)
public long getUpdateCount()
public void incrementUpdateCount()
Copyright © 2022 The Apache Software Foundation. All rights reserved.