Method CreateNullTuple

be/src/exec/unnest-node.cc:223–235

}

Tuple* UnnestNode::CreateNullTuple(int coll_idx, RowBatch* row_batch) const {
  const TupleDescriptor* coll_tuple =
      (*coll_slot_descs_)[coll_idx]->children_tuple_descriptor();
  DCHECK(coll_tuple != nullptr);
  if (coll_tuple->slots().size() == 0) return nullptr;
  DCHECK_EQ(coll_tuple->slots().size(), 1);
  const SlotDescriptor* coll_item_slot = coll_tuple->slots()[0];
  DCHECK(coll_item_slot != nullptr);
  Tuple* tuple = Tuple::Create(item_byte_sizes_[coll_idx], row_batch->tuple_data_pool());
  if (tuple == nullptr) return nullptr;
  tuple->SetNull(coll_item_slot->null_indicator_offset());
  return tuple;
}

Status UnnestNode::Reset(RuntimeState* state, RowBatch* row_batch) {
  item_idx_ = 0;