Function InitTable

src/sample/global_txn_async_sample.cc:21–38

};

tera::Table* InitTable(tera::Client* client, const std::string& tablename) {
  tera::ErrorCode error_code;
  if (!client->IsTableExist(tablename, &error_code)) {
    tera::TableDescriptor schema(tablename);
    schema.EnableTxn();  // 参与全局事务的表schema 都需要设置 txn=true
    schema.AddLocalityGroup("lg0");
    tera::ColumnFamilyDescriptor* cfd1 = schema.AddColumnFamily("cf1");
    cfd1->EnableGlobalTransaction();
    tera::ColumnFamilyDescriptor* cfd2 = schema.AddColumnFamily("cf2");
    cfd2->DisableGlobalTransaction();
    client->CreateTable(schema, &error_code);
    assert(error_code.GetType() == tera::ErrorCode::kOK);
  }

  tera::Table* table = client->OpenTable(tablename, &error_code);
  assert(table && error_code.GetType() == tera::ErrorCode::kOK);
  return table;
}

void TxnCallBack(tera::Transaction* txn) {
  if (txn->GetError().GetType() != tera::ErrorCode::kOK) {