Method refresh

be/src/util/event-metrics.cc:173–268

}

void MetastoreEventMetrics::refresh(TEventProcessorMetrics* response) {
  if (!response) {
    LOG(ERROR)
        << "Received a null response when trying to refresh metastore event metrics";
    return;
  }
  EVENT_PROCESSOR_STATUS->SetValue(response->status.c_str());

  if (response->__isset.events_received) {
    NUM_EVENTS_RECEIVED_COUNTER->SetValue(response->events_received);
  }
  if (response->__isset.events_skipped) {
    NUM_EVENTS_SKIPPED_COUNTER->SetValue(response->events_skipped);
  }
  if (response->__isset.events_fetch_duration_mean) {
    EVENTS_FETCH_DURATION_MEAN->SetValue(response->events_fetch_duration_mean);
  }
  if (response->__isset.events_fetch_duration_p75) {
    EVENTS_FETCH_DURATION_P75->SetValue(response->events_fetch_duration_p75);
  }
  if (response->__isset.events_fetch_duration_p95) {
    EVENTS_FETCH_DURATION_P95->SetValue(response->events_fetch_duration_p95);
  }
  if (response->__isset.events_fetch_duration_p99) {
    EVENTS_FETCH_DURATION_P99->SetValue(response->events_fetch_duration_p99);
  }
  if (response->__isset.last_events_fetch_duration) {
    EVENTS_FETCH_LAST_DURATION->SetValue(response->last_events_fetch_duration);
  }
  if (response->__isset.events_process_duration_mean) {
    EVENTS_PROCESS_DURATION_MEAN->SetValue(response->events_process_duration_mean);
  }
  if (response->__isset.events_process_duration_p75) {
    EVENTS_PROCESS_DURATION_P75->SetValue(response->events_process_duration_p75);
  }
  if (response->__isset.events_process_duration_p95) {
    EVENTS_PROCESS_DURATION_P95->SetValue(response->events_process_duration_p95);
  }
  if (response->__isset.events_process_duration_p99) {
    EVENTS_PROCESS_DURATION_P99->SetValue(response->events_process_duration_p99);
  }
  if (response->__isset.last_events_process_duration) {
    EVENTS_PROCESS_LAST_DURATION->SetValue(response->last_events_process_duration);
  }
  if (response->__isset.events_received_1min_rate) {
    EVENTS_RECEIVED_1MIN_RATE->SetValue(response->events_received_1min_rate);
  }
  if (response->__isset.events_received_5min_rate) {
    EVENTS_RECEIVED_5MIN_RATE->SetValue(response->events_received_1min_rate);
  }
  if (response->__isset.events_received_15min_rate) {
    EVENTS_RECEIVED_15MIN_RATE->SetValue(response->events_received_15min_rate);
  }
  if (response->__isset.last_synced_event_id) {
    LAST_SYNCED_EVENT_ID->SetValue(response->last_synced_event_id);
  }
  if (response->__isset.last_synced_event_time) {
    LAST_SYNCED_EVENT_TIME->SetValue(response->last_synced_event_time);