Method BackendResourceUtilization

be/src/runtime/coordinator.cc:1588–1600

}

list<pair<NetworkAddressPB, Coordinator::ResourceUtilization>>
    Coordinator::BackendResourceUtilization() {
  DCHECK(exec_rpcs_complete_.Load()) << "Exec() must be called first.";
  list<pair<NetworkAddressPB, Coordinator::ResourceUtilization>> result;

  lock_guard<SpinLock> l(backend_states_init_lock_);
  for (BackendState* backend_state : backend_states_) {
    result.push_back(make_pair(backend_state->impalad_address(),
        backend_state->GetResourceUtilization()));
  }

  return result;
}

void Coordinator::UpdateFilter(const UpdateFilterParamsPB& params, RpcContext* context) {
  VLOG(2) << "Coordinator::UpdateFilter(filter_id=" << params.filter_id() << ")";