Method Scan

src/benchmark/mark.cc:425–454

}

void Adapter::Scan(const std::string& start_key, const std::string& end_key,
                   const std::vector<std::string>& cf_list, bool print, bool is_async) {
  tera::ScanDescriptor scan_desp(start_key);
  scan_desp.SetEnd(end_key);
  scan_desp.SetBufferSize(FLAGS_buf_size);
  for (size_t i = 0; i < cf_list.size(); i++) {
    scan_desp.AddColumnFamily(cf_list[i]);
  }
  tera::ErrorCode err;
  tera::ResultStream* result = table_->Scan(scan_desp, &err);
  if (result == NULL) {
    std::cerr << "fail to scan: " << tera::strerr(err);
    return;
  }

  uint64_t count = 0;
  while (!result->Done()) {
    if (print) {
      std::cerr << count++ << "\t" << result->RowName() << "\t" << result->Family() << "\t"
                << result->Qualifier() << "\t" << result->Timestamp() << "\t" << result->Value()
                << std::endl;
    }
    size_t size = result->RowName().size() + result->Family().size() + result->Qualifier().size() +
                  sizeof(result->Timestamp()) + result->Value().size();
    scan_marker_.OnFinish(size, 0);
    scan_marker_.OnSuccess(size, 0);
    result->Next();
  }
  delete result;
}

void Adapter::WaitComplete() {
  pthread_mutex_lock(&mutex_);