Method Scan

src/sdk/table_impl.cc:392–412

}

ResultStream* TableImpl::Scan(const ScanDescriptor& desc, ErrorCode* err) {
  ScanDescImpl impl(*desc.GetImpl());
  if (impl.GetFilterDesc() && impl.GetMaxVersion() != 1) {
    LOG(ERROR) << "when scan with a filter, only support max_version of scanner == 1";
    return NULL;
  }
  if (IsHashTable()) {
    if (!impl.GetStartRowKey().empty()) {
      impl.SetStart(hash_method_(impl.GetStartRowKey()), impl.GetStartColumnFamily(),
                    impl.GetStartQualifier(), impl.GetStartTimeStamp());
    }
    if (!impl.GetEndRowKey().empty()) {
      impl.SetEnd(hash_method_(impl.GetEndRowKey()));
    }
  }
  impl.SetTableSchema(table_schema_);
  ResultStream* results = NULL;
  VLOG(6) << "activate async-scan";
  results = new ResultStreamImpl(this, &impl);
  return results;
}

void TableImpl::ScanTabletAsync(ResultStreamImpl* stream) {
  ScanTask* scan_task = new ScanTask;