Function EstimateSize

be/src/service/query-state-record.cc:164–210

}

int64_t EstimateSize(const QueryStateRecord* record) {
  int64_t size = sizeof(QueryStateRecord); // 800
  size += sizeof(uint8_t) * record->compressed_profile.capacity();
  size += record->effective_user.capacity();
  size += record->default_db.capacity();
  size += record->stmt.capacity();
  size += record->plan.capacity();
  size += record->query_state.capacity();
  size += record->timeline.capacity();
  size += record->resource_pool.capacity();

  // The following dynamic memory of field members are estimated rather than
  // exactly sized. Some of thrift members might be nested, but the estimation
  // does not traverse deeper than the first level.

  // TExecSummary exec_summary
  if (record->exec_summary.__isset.nodes) {
    size += sizeof(TPlanNodeExecSummary) * record->exec_summary.nodes.capacity();
  }
  if (record->exec_summary.__isset.exch_to_sender_map) {
    size += sizeof(int32_t) * 2 * record->exec_summary.exch_to_sender_map.size();
  }
  if (record->exec_summary.__isset.error_logs) {
    for (const auto& log : record->exec_summary.error_logs) size += log.capacity();
  }
  if (record->exec_summary.__isset.queued_reason) {
    size += record->exec_summary.queued_reason.capacity();
  }

  // Status query_status
  if (!record->query_status.ok()) {
    size += record->query_status.msg().msg().capacity();
    for (const auto& detail : record->query_status.msg().details()) {
      size += detail.capacity();
    }
  }

  // TEventSequence event_sequence
  size += record->event_sequence.name.capacity();
  size += sizeof(int64_t) * record->event_sequence.timestamps.capacity();
  for (const auto& label : record->event_sequence.labels) size += label.capacity();

  // vector<TPlanFragment> fragments
  size += sizeof(TPlanFragment) * record->fragments.capacity();

  return size;
}

static bool find_instance(RuntimeProfileBase* prof) {
  return boost::algorithm::istarts_with(prof->name(), "Instance");