All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
void |
addAggregateStatsToCache(String catName,
String dbName,
String tblName,
AggrStats aggrStatsAllPartitions,
AggrStats aggrStatsAllButDefaultPartition) |
void |
addCatalogToCache(Catalog cat) |
void |
addCheckConstraintsToCache(String catName,
String dbName,
String tblName,
List<SQLCheckConstraint> keys) |
void |
addDatabaseToCache(Database db) |
void |
addDefaultConstraintsToCache(String catName,
String dbName,
String tblName,
List<SQLDefaultConstraint> keys) |
void |
addForeignKeysToCache(String catName,
String dbName,
String tblName,
List<SQLForeignKey> keys) |
void |
addNotNullConstraintsToCache(String catName,
String dbName,
String tblName,
List<SQLNotNullConstraint> keys) |
void |
addPartitionsToCache(String catName,
String dbName,
String tblName,
Iterable<Partition> parts) |
void |
addPartitionToCache(String catName,
String dbName,
String tblName,
Partition part) |
void |
addPrimaryKeysToCache(String catName,
String dbName,
String tblName,
List<SQLPrimaryKey> keys) |
void |
addTableConstraintsToCache(String catName,
String dbName,
String tblName,
SQLAllTableConstraints constraints) |
org.apache.hadoop.hive.metastore.cache.SharedCache.TableWrapper |
addTableToCache(String catName,
String dbName,
String tblName,
Table tbl) |
void |
addUniqueConstraintsToCache(String catName,
String dbName,
String tblName,
List<SQLUniqueConstraint> keys) |
void |
alterCatalogInCache(String catName,
Catalog newCat) |
void |
alterDatabaseInCache(String catName,
String dbName,
Database newDb)
Replaces the old db object with the new one.
|
void |
alterPartitionAndStatsInCache(String catName,
String dbName,
String tblName,
long writeId,
List<String> partVals,
Map<String,String> parameters,
List<ColumnStatisticsObj> colStatsObjs) |
void |
alterPartitionInCache(String catName,
String dbName,
String tblName,
List<String> partVals,
Partition newPart) |
void |
alterPartitionsInCache(String catName,
String dbName,
String tblName,
List<List<String>> partValsList,
List<Partition> newParts) |
void |
alterTableAndStatsInCache(String catName,
String dbName,
String tblName,
long writeId,
List<ColumnStatisticsObj> colStatsObjs,
Map<String,String> newParams) |
void |
alterTableInCache(String catName,
String dbName,
String tblName,
Table newTable) |
void |
completeTableCachePrewarm() |
void |
decrSd(byte[] sdHash) |
boolean |
existPartitionFromCache(String catName,
String dbName,
String tblName,
List<String> partVals) |
List<ColumnStatisticsObj> |
getAggrStatsFromCache(String catName,
String dbName,
String tblName,
List<String> colNames,
org.apache.hadoop.hive.metastore.cache.SharedCache.StatsType statsType) |
int |
getCachedDatabaseCount() |
int |
getCachedTableCount() |
Catalog |
getCatalogFromCache(String name) |
Database |
getDatabaseFromCache(String catName,
String name) |
int |
getObjectSize(Class<?> clazz,
Object obj) |
SharedCache.ColumStatsWithWriteId |
getPartitionColStatsFromCache(String catName,
String dbName,
String tblName,
List<String> partVal,
String colName,
String writeIdList) |
List<ColumnStatistics> |
getPartitionColStatsListFromCache(String catName,
String dbName,
String tblName,
List<String> partNames,
List<String> colNames,
String writeIdList,
boolean txnStatSupported) |
Partition |
getPartitionFromCache(String catName,
String dbName,
String tblName,
List<String> partVals) |
StorageDescriptor |
getSdFromCache(byte[] sdHash) |
ColumnStatistics |
getTableColStatsFromCache(String catName,
String dbName,
String tblName,
List<String> colNames,
String validWriteIds,
boolean areTxnStatsSupported) |
Table |
getTableFromCache(String catName,
String dbName,
String tableName) |
List<TableMeta> |
getTableMeta(String catName,
String dbNames,
String tableNames,
List<String> tableTypes) |
long |
getUpdateCount() |
void |
incrementUpdateCount() |
void |
increSd(StorageDescriptor sd,
byte[] sdHash) |
void |
initialize(org.apache.hadoop.conf.Configuration conf) |
boolean |
isCatalogCachePrewarmed() |
boolean |
isDatabaseCachePrewarmed() |
boolean |
isTableConstraintValid(String catName,
String dbName,
String tblName) |
SQLAllTableConstraints |
listCachedAllTableConstraints(String catName,
String dbName,
String tblName) |
List<String> |
listCachedCatalogs() |
List<SQLCheckConstraint> |
listCachedCheckConstraint(String catName,
String dbName,
String tblName) |
List<String> |
listCachedDatabases(String catName) |
List<String> |
listCachedDatabases(String catName,
String pattern) |
List<SQLDefaultConstraint> |
listCachedDefaultConstraint(String catName,
String dbName,
String tblName) |
List<SQLForeignKey> |
listCachedForeignKeys(String catName,
String foreignDbName,
String foreignTblName,
String parentDbName,
String parentTblName) |
List<SQLNotNullConstraint> |
listCachedNotNullConstraints(String catName,
String dbName,
String tblName) |
List<Partition> |
listCachedPartitions(String catName,
String dbName,
String tblName,
int max) |
List<SQLPrimaryKey> |
listCachedPrimaryKeys(String catName,
String dbName,
String tblName) |
List<String> |
listCachedTableNames(String catName,
String dbName) |
List<String> |
listCachedTableNames(String catName,
String dbName,
String pattern,
int maxTables) |
List<String> |
listCachedTableNames(String catName,
String dbName,
String pattern,
TableType tableType,
int limit) |
List<Table> |
listCachedTables(String catName,
String dbName) |
List<SQLUniqueConstraint> |
listCachedUniqueConstraint(String catName,
String dbName,
String tblName) |
void |
populateCatalogsInCache(Collection<Catalog> catalogs) |
void |
populateDatabasesInCache(List<Database> databases) |
boolean |
populateTableInCache(Table table,
TableCacheObjects cacheObjects) |
void |
printCacheStats() |
void |
refreshAggregateStatsInCache(String catName,
String dbName,
String tblName,
AggrStats aggrStatsAllPartitions,
AggrStats aggrStatsAllButDefaultPartition,
Map<List<String>,Long> partNameToWriteId) |
void |
refreshAllTableConstraintsInCache(String catName,
String dbName,
String tblName,
SQLAllTableConstraints constraints) |
boolean |
refreshDatabasesInCache(List<Database> databases) |
void |
refreshPartitionColStatsInCache(String catName,
String dbName,
String tblName,
List<ColumnStatistics> partitionColStats) |
void |
refreshPartitionsInCache(String catName,
String dbName,
String tblName,
List<Partition> partitions) |
void |
refreshTableColStatsInCache(String catName,
String dbName,
String tableName,
List<ColumnStatisticsObj> colStatsForTable) |
boolean |
refreshTablesInCache(String catName,
String dbName,
List<Table> tables) |
void |
removeAllPartitionColStatsFromCache(String catName,
String dbName,
String tblName) |
void |
removeAllTableColStatsFromCache(String catName,
String dbName,
String tblName) |
void |
removeCatalogFromCache(String name) |
void |
removeConstraintFromCache(String catName,
String dbName,
String tblName,
String constraintName) |
void |
removeDatabaseFromCache(String catName,
String dbName) |
void |
removePartitionColStatsFromCache(String catName,
String dbName,
String tblName,
List<String> partVals,
String colName) |
Partition |
removePartitionFromCache(String catName,
String dbName,
String tblName,
List<String> partVals) |
void |
removePartitionsFromCache(String catName,
String dbName,
String tblName,
List<List<String>> partVals) |
void |
removeTableColStatsFromCache(String catName,
String dbName,
String tblName,
String colName) |
void |
removeTableFromCache(String catName,
String dbName,
String tblName) |
void |
setConcurrencyLevel(int cl) |
void |
setRefreshInterval(int interval) |
void |
setTableSizeMap(Map<String,Integer> map) |
void |
updatePartitionColStatsInCache(String catName,
String dbName,
String tableName,
List<String> partVals,
List<ColumnStatisticsObj> colStatsObjs) |
void |
updateTableColStatsInCache(String catName,
String dbName,
String tableName,
List<ColumnStatisticsObj> colStatsForTable) |