Method GetNext

be/src/exec/singular-row-src-node.cc:36–48

  : ExecNode(pool, pnode, descs) {}

Status SingularRowSrcNode::GetNext(RuntimeState* state, RowBatch* row_batch, bool* eos) {
  // We do not time this function, check for cancellation, or perform the usual per-batch
  // query maintenance because those would dominate the execution cost of this node.
  DCHECK(containing_subplan_ != NULL) << "set_containing_subplan() must be called";

  // Only produces a single row per GetNext() call.
  *eos = true;
  int row_idx = row_batch->AddRow();
  TupleRow* row = row_batch->GetRow(row_idx);
  row_batch->CopyRow(containing_subplan_->current_row(), row);
  row_batch->CommitLastRow();
  return Status::OK();
}

}