Method CreateInternal

be/src/runtime/descriptors.cc:666–705

}

Status DescriptorTbl::CreateInternal(ObjectPool* pool, const TDescriptorTable& thrift_tbl,
    DescriptorTbl** tbl) {
  *tbl = pool->Add(new DescriptorTbl());
  // deserialize table descriptors first, they are being referenced by tuple descriptors
  for (const TTableDescriptor& tdesc: thrift_tbl.tableDescriptors) {
    TableDescriptor* desc;
    RETURN_IF_ERROR(CreateTblDescriptorInternal(tdesc, pool, &desc));
    (*tbl)->tbl_desc_map_[tdesc.id] = desc;
  }

  for (const TTupleDescriptor& tdesc : thrift_tbl.tupleDescriptors) {
    TupleDescriptor* desc = pool->Add(new TupleDescriptor(tdesc));
    // fix up table pointer
    if (tdesc.__isset.tableId) {
      desc->table_desc_ = (*tbl)->GetTableDescriptor(tdesc.tableId);
    }
    (*tbl)->tuple_desc_map_[tdesc.id] = desc;
  }

  for (const TSlotDescriptor& tdesc : thrift_tbl.slotDescriptors) {
    // Tuple descriptors are already populated in tbl
    TupleDescriptor* parent = (*tbl)->GetTupleDescriptor(tdesc.parent);
    DCHECK(parent != nullptr);
    TupleDescriptor* children_tuple_descriptor = tdesc.__isset.itemTupleId ?
        (*tbl)->GetTupleDescriptor(tdesc.itemTupleId) : nullptr;
    SlotDescriptor* slot_d = pool->Add(
        new SlotDescriptor(tdesc, parent, children_tuple_descriptor));
    if (slot_d->type().IsStructType() && children_tuple_descriptor != nullptr &&
        children_tuple_descriptor->getMasterTuple() == nullptr) {
      TupleDescriptor* master_tuple = parent;
      // If this struct is nested into other struct(s) then get the topmost tuple for the
      // master.
      if (parent->getMasterTuple() != nullptr) master_tuple = parent->getMasterTuple();
      children_tuple_descriptor->setMasterTuple(master_tuple);
    }
    (*tbl)->slot_desc_map_[tdesc.id] = slot_d;
    parent->AddSlot(slot_d);
  }
  return Status::OK();
}

void DescriptorTbl::ReleaseResources() {
  // close partition exprs of hdfs tables