Method StructValToJSON

be/src/runtime/complex-value-writer.inline.h:242–274

template <class JsonStream>
void ComplexValueWriter<JsonStream>::StructValToJSON(const StructVal& struct_val,
    const SlotDescriptor& slot_desc) {
  const ColumnType& struct_type = slot_desc.type();
  DCHECK(struct_type.type == TYPE_STRUCT);
  DCHECK_EQ(struct_val.num_children, struct_type.children.size());

  const TupleDescriptor* children_item_tuple_desc = slot_desc.children_tuple_descriptor();
  DCHECK(children_item_tuple_desc != nullptr);
  const std::vector<SlotDescriptor*>& child_slot_descs =
      children_item_tuple_desc->slots();
  DCHECK_EQ(struct_val.num_children, child_slot_descs.size());

  writer_->StartObject();
  for (int i = 0; i < struct_val.num_children; ++i) {
    writer_->String(struct_type.field_names[i].c_str());
    void* child = (void*)(struct_val.ptr[i]);
    const SlotDescriptor& child_slot_desc = *child_slot_descs[i];
    const ColumnType& child_type = struct_type.children[i];
    DCHECK_EQ(child_type, child_slot_desc.type());
    if (child == nullptr) {
      WriteNull(false);
    } else if (child_type.IsStructType()) {
      StructValToJSON(*((StructVal*)child), child_slot_desc);
    } else if (child_type.IsCollectionType()) {
      CollectionValue* collection_child = reinterpret_cast<CollectionValue*>(child);
      ComplexValueWriter::CollectionValueToJSON(*collection_child, child_type.type,
          child_slot_desc.children_tuple_descriptor());
    } else {
      PrimitiveValueToJSON(child, child_type, false);
    }
  }
  writer_->EndObject();
}

} // namespace impala