Function SinkToJsonHelper

be/src/service/impala-http-handler.cc:1214–1256

Helper for PlanToJson(), called only when the plan fragment's root data sink must be one of the following types: - table sink, - multi data sink, - merge sink. Plan nodes of the plan fragment will be listed as children of the root data sink.

//  - merge sink.
// Plan nodes of the plan fragment will be listed as children of the root data sink.
void SinkToJsonHelper(const TDataSink& sink,
    const map<TPlanNodeId, TPlanNodeExecSummary>& summaries,
    vector<TPlanNode>::const_iterator* it, rapidjson::Document* document, Value* value) {
  Value label(sink.label, document->GetAllocator());
  value->AddMember("label", label, document->GetAllocator());

  string label_detail_str = "";
  switch (sink.type) {
    case TDataSinkType::type::MERGE_SINK:
    case TDataSinkType::type::MULTI_DATA_SINK:
      label_detail_str = sink.child_data_sinks.at(0).label;
      for (std::size_t i = 1; i < sink.child_data_sinks.size(); ++i) {
        label_detail_str += ", ";
        label_detail_str += sink.child_data_sinks.at(i).label;
      }
      break;
    case TDataSinkType::type::TABLE_SINK:
      label_detail_str = to_string(sink.table_sink.action);
      break;
    default:
      // Should not call SinkToJsonHelper() with any other sink type.
      DCHECK(false) << "Invalid sink type: " << sink.type;
  }
  Value label_detail(label_detail_str, document->GetAllocator());
  value->AddMember("label_detail", label_detail, document->GetAllocator());

  map<TPlanNodeId, TPlanNodeExecSummary>::const_iterator summary_it =
      summaries.find(SINK_NODE_ID);
  if (summary_it != summaries.end()) {
    // Sometimes we don't have a summary for the sink, e.g.:
    // - Query was rejected by admission control
    // - CTAS query failed to create the target table, so the sink was never executed
    ExecStatsToJsonHelper(summary_it->second, document, value);
  }

  Value children(kArrayType);

  Value container(kObjectType);
  PlanToJsonHelper(summaries, it, document, &container);
  children.PushBack(container, document->GetAllocator());

  value->AddMember("children", children, document->GetAllocator());
}

} // unnamed namespace