Method GetNext

be/src/exec/system-table-scan-node.cc:59–90

}

Status SystemTableScanNode::GetNext(RuntimeState* state, RowBatch* row_batch, bool* eos) {
  SCOPED_TIMER(runtime_profile_->total_time_counter());
  ScopedGetNextEventAdder ea(this, eos);
  RETURN_IF_ERROR(ExecDebugAction(TExecNodePhase::GETNEXT, state));
  RETURN_IF_CANCELLED(state);
  RETURN_IF_ERROR(QueryMaintenance(state));

  int64_t tuple_buffer_size;
  uint8_t* tuple_mem;
  RETURN_IF_ERROR(
      row_batch->ResizeAndAllocateTupleBuffer(state, &tuple_buffer_size, &tuple_mem));

  SCOPED_TIMER(materialize_tuple_timer());

  // copy rows until we hit the limit/capacity or until we exhaust input batch
  while (!ReachedLimit() && !row_batch->AtCapacity() && !scanner_->eos()) {
    Tuple* tuple = reinterpret_cast<Tuple*>(tuple_mem);
    RETURN_IF_ERROR(MaterializeNextTuple(row_batch->tuple_data_pool(), tuple));
    TupleRow* tuple_row = row_batch->GetRow(row_batch->AddRow());
    tuple_row->SetTuple(0, tuple);

    if (ExecNode::EvalConjuncts(
            conjunct_evals_.data(), conjunct_evals_.size(), tuple_row)) {
      row_batch->CommitLastRow();
      tuple_mem += tuple_desc_->byte_size();
      IncrementNumRowsReturned(1);
    }
  }
  COUNTER_SET(rows_returned_counter_, rows_returned());
  *eos = ReachedLimit() || scanner_->eos();
  return Status::OK();
}

Status SystemTableScanNode::Reset(RuntimeState* state, RowBatch* row_batch) {
  DCHECK(false) << "NYI";