Method PrintComplexValue

be/src/service/query-result-set.cc:235–273

}

void QueryResultSet::PrintComplexValue(ScalarExprEvaluator* expr_eval,
    const TupleRow* row, stringstream *stream, const ColumnType& type,
    bool stringify_map_keys) {
  DCHECK(type.IsComplexType());
  const ScalarExpr& scalar_expr = expr_eval->root();
  // Currently scalar_expr can be only a slot ref as no functions return complex types.
  DCHECK(scalar_expr.IsSlotRef());
  void* value = expr_eval->GetValue(row);

  if (value == nullptr) {
    (*stream) << RawValue::NullLiteral(/*top-level*/ true);
    return;
  }

  rapidjson::BasicOStreamWrapper<stringstream> wrapped_stream(*stream);
  rapidjson::Writer<rapidjson::BasicOStreamWrapper<stringstream>> writer(wrapped_stream);

  if (type.IsCollectionType()) {
    const CollectionValue* collection_val = static_cast<const CollectionValue*>(value);
    const TupleDescriptor* item_tuple_desc = scalar_expr.GetCollectionTupleDesc();
    DCHECK(item_tuple_desc != nullptr);

    ComplexValueWriter<rapidjson::BasicOStreamWrapper<stringstream>>
        complex_value_writer(&writer, stringify_map_keys);
    complex_value_writer.CollectionValueToJSON(*collection_val, type.type,
            item_tuple_desc);
  } else {
    DCHECK(type.IsStructType());
    const StructVal* struct_val = static_cast<const StructVal*>(value);
    const SlotDescriptor* slot_desc =
        static_cast<const SlotRef&>(scalar_expr).GetSlotDescriptor();
    DCHECK(slot_desc != nullptr);
    DCHECK_EQ(type, slot_desc->type());

    ComplexValueWriter<rapidjson::BasicOStreamWrapper<stringstream>>
        complex_value_writer(&writer, stringify_map_keys);
    complex_value_writer.StructValToJSON(*struct_val, *slot_desc);
  }
}

Status AsciiQueryResultSet::AddOneRow(const TResultRow& row) {
  int num_col = row.colVals.size();