Method StructInCollectionToJSON

be/src/runtime/complex-value-writer.inline.h:102–142

// tuple.
template <class JsonStream>
void ComplexValueWriter<JsonStream>::StructInCollectionToJSON(Tuple* item_tuple,
    const SlotDescriptor& struct_slot_desc) {
  const TupleDescriptor* children_tuple_desc =
      struct_slot_desc.children_tuple_descriptor();
  DCHECK(children_tuple_desc != nullptr);

  const ColumnType& struct_type = struct_slot_desc.type();
  const std::vector<SlotDescriptor*>& child_slots = children_tuple_desc->slots();

  DCHECK(struct_type.type == TYPE_STRUCT);
  DCHECK_EQ(child_slots.size(), struct_type.children.size());

  writer_->StartObject();
  for (int i = 0; i < child_slots.size(); ++i) {
    writer_->String(struct_type.field_names[i].c_str());

    const SlotDescriptor& child_slot_desc = *child_slots[i];
    bool element_is_null = item_tuple->IsNull(child_slot_desc.null_indicator_offset());
    if (element_is_null) {
      WriteNull(writer_);
      continue;
    }

    const ColumnType& child_type = child_slot_desc.type();
    void* child = item_tuple->GetSlot(child_slot_desc.tuple_offset());
    if (child_type.IsStructType()) {
      StructInCollectionToJSON(item_tuple, child_slot_desc);
    } else if (child_type.IsCollectionType()) {
      const CollectionValue* nested_collection_val =
          reinterpret_cast<CollectionValue*>(child);
      const TupleDescriptor* child_item_tuple_desc =
          child_slot_desc.children_tuple_descriptor();
      DCHECK(child_item_tuple_desc != nullptr);
      CollectionValueToJSON(*nested_collection_val, child_type.type,
          child_item_tuple_desc);
    } else {
      PrimitiveValueToJSON(child, child_type, false);
    }
  }
  writer_->EndObject();
}

template <class JsonStream>
void ComplexValueWriter<JsonStream>::CollectionElementToJSON(Tuple* item_tuple,