| 33 | } |
| 34 | |
| 35 | void dropStatsColumns( |
| 36 | ContextPtr context, |
| 37 | const StatsTableIdentifier & table, |
| 38 | const std::vector<String> & columns, |
| 39 | StatisticsCachePolicy cache_policy, |
| 40 | bool throw_exception) |
| 41 | { |
| 42 | try |
| 43 | { |
| 44 | auto catalog = createCatalogAdaptor(context); |
| 45 | catalog->checkHealth(/*is_write=*/true); |
| 46 | auto proxy = createCachedStatsProxy(catalog, cache_policy); |
| 47 | auto cols_desc = catalog->filterCollectableColumns(table, columns); |
| 48 | proxy->dropColumns(table, cols_desc); |
| 49 | catalog->invalidateClusterStatsCache(table); |
| 50 | } |
| 51 | catch (...) |
| 52 | { |
| 53 | if (throw_exception) |
| 54 | throw; |
| 55 | } |
| 56 | } |
| 57 | |
| 58 | } |
no test coverage detected