Method GetTableTransactionType

src/observer/executor/scanner_impl.cc:595–612

}

TransactionType ScannerImpl::GetTableTransactionType(tera::Table* table) {
  tera::ErrorCode err;
  std::shared_ptr<Table> table_ptr;
  table_ptr.reset(tera_client_->OpenTable(table->GetName(), &err));
  std::shared_ptr<TableImpl> table_impl(
      static_cast<TableWrapper*>(table_ptr.get())->GetTableImpl());
  TableSchema schema = table_impl->GetTableSchema();

  if (IsTransactionTable(schema)) {
    std::set<std::string> gtxn_cfs;
    FindGlobalTransactionCfs(schema, &gtxn_cfs);
    if (gtxn_cfs.size() > 0) {
      return kGlobalTransaction;
    }
    return kSingleRowTransaction;
  }
  return kNoneTransaction;
}

void ScannerImpl::ValidateCellValue(RowReader* value_reader) {
  std::unique_ptr<NotificationContext> context((NotificationContext*)(value_reader->GetContext()));