Method AddStream

be/src/exec/scanner-context.cc:89–93

}

ScannerContext::Stream* ScannerContext::AddStream(ScanRange* range, int64_t reservation) {
  streams_.emplace_back(new Stream(this, range, reservation,
      scan_node_->GetFileDesc(partition_desc_->id(), range->file())));
  return streams_.back().get();
}

Status ScannerContext::AddAndStartStream(
    ScanRange* range, int64_t reservation, ScannerContext::Stream** stream) {