Method InitCollExprs

be/src/exec/unnest-node.cc:51–75

}

Status UnnestPlanNode::InitCollExprs(FragmentState* state) {
  DCHECK(containing_subplan_ != nullptr)
      << "set_containing_subplan() must have been called";
  const RowDescriptor& row_desc = *containing_subplan_->children_[0]->row_descriptor_;
  RETURN_IF_ERROR(ScalarExpr::Create(
      tnode_->unnest_node.collection_exprs, row_desc, state, &collection_exprs_));
  DCHECK_GT(collection_exprs_.size(), 0);

  for (ScalarExpr* coll_expr : collection_exprs_) {
    DCHECK(coll_expr->IsSlotRef());
    const SlotRef* slot_ref = static_cast<SlotRef*>(coll_expr);
    SlotDescriptor* slot_desc = state->desc_tbl().GetSlotDescriptor(slot_ref->slot_id());
    DCHECK(slot_desc != nullptr);
    coll_slot_descs_.push_back(slot_desc);

    // If the collection is in a struct we don't use the itemTupleDesc of the struct but
    // the tuple in which the top level struct is placed.
    const TupleDescriptor* parent_tuple = slot_desc->parent();
    const TupleDescriptor* master_tuple = parent_tuple->getMasterTuple();
    const TupleDescriptor* top_level_tuple = master_tuple == nullptr ?
        parent_tuple : master_tuple;
    coll_tuple_idxs_.push_back(row_desc.GetTupleIdx(top_level_tuple->id()));
  }
  return Status::OK();
}

Status UnnestPlanNode::CreateExecNode(RuntimeState* state, ExecNode** node) const {
  ObjectPool* pool = state->obj_pool();