MCPcopy Create free account
hub / github.com/apache/impala / UpdateCatalogVersionMetrics

Method UpdateCatalogVersionMetrics

be/src/service/impala-server.cc:2433–2439  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2431}
2432
2433void ImpalaServer::CatalogUpdateVersionInfo::UpdateCatalogVersionMetrics() {
2434 ImpaladMetrics::CATALOG_VERSION->SetValue(catalog_version);
2435 ImpaladMetrics::CATALOG_OBJECT_VERSION_LOWER_BOUND->SetValue(
2436 catalog_object_version_lower_bound);
2437 ImpaladMetrics::CATALOG_TOPIC_VERSION->SetValue(catalog_topic_version);
2438 ImpaladMetrics::CATALOG_SERVICE_ID->SetValue(PrintId(catalog_service_id));
2439}
2440
2441void ImpalaServer::CatalogUpdateCallback(
2442 const StatestoreSubscriber::TopicDeltaMap& incoming_topic_deltas,

Callers 1

CatalogUpdateCallbackMethod · 0.80

Calls 2

PrintIdFunction · 0.85
SetValueMethod · 0.45

Tested by

no test coverage detected