Function ScanTable

src/sample/tera_sample.cc:101–122

扫描一个表

/// 扫描一个表
int ScanTable(tera::Table* table) {
  tera::ErrorCode error_code;

  // 创建一个scan表述
  tera::ScanDescriptor scan_desc("com.baidu.");
  // 只扫描百度主域
  scan_desc.SetEnd("com.baidu.~");
  // 设置扫描的column family
  scan_desc.AddColumnFamily("anchor");
  // 设置最多返回的版本
  scan_desc.SetMaxVersions(3);
  // 设置扫描的时间范围
  scan_desc.SetTimeRange(time(NULL), time(NULL) - 3600);

  tera::ResultStream* scanner = table->Scan(scan_desc, &error_code);
  for (scanner->LookUp("com.baidu."); !scanner->Done(); scanner->Next()) {
    printf("Row: %s\%s\%ld\%s\n", scanner->RowName().c_str(), scanner->ColumnName().c_str(),
           scanner->Timestamp(), scanner->Value().c_str());
  }
  delete scanner;
  return 0;
}

bool finish = false;