Method ParseNotifyQualifier

src/observer/executor/scanner_impl.cc:399–429

example qualifier: C:url C: cf; column: url;

// example qualifier: C:url
// C: cf; column: url;
bool ScannerImpl::ParseNotifyQualifier(const std::string& notify_qualifier,
                                       std::string* data_family, std::string* data_qualifier) {
  std::vector<std::string> frags;
  std::size_t pos = std::string::npos;
  std::size_t start_pos = 0;
  std::string frag;

  // parse cf
  pos = notify_qualifier.find_first_of(':', start_pos);
  if (pos == std::string::npos) {
    LOG(ERROR) << "Parse notify qualifier error: " << notify_qualifier;
    return false;
  }
  frag = notify_qualifier.substr(start_pos, pos - start_pos);
  frags.push_back(frag);
  start_pos = pos + 1;

  pos = notify_qualifier.size();
  frag = notify_qualifier.substr(start_pos, pos - start_pos);
  frags.push_back(frag);
  if (2 != frags.size()) {
    return false;
  }
  if (frags[0] == "" || frags[1] == "") {
    return false;
  }
  *data_family = frags[0];
  *data_qualifier = frags[1];

  return true;
}

void ScannerImpl::AsyncReadCell(std::shared_ptr<NotifyCell> notify_cell) {
  VLOG(12) << "[time] do read value start. [row] " << notify_cell->row << " cf:qu "