Method UpdateTable

src/sdk/client_impl.cc:282–335

}

bool ClientImpl::UpdateTable(const TableDescriptor& desc, ErrorCode* err) {
  if (!IsTableExist(desc.TableName(), err)) {
    LOG(ERROR) << "table not exist: " << desc.TableName();
    return false;
  }

  master::MasterClient master_client(cluster_->MasterAddr());

  UpdateTableRequest request;
  UpdateTableResponse response;
  request.set_sequence_id(g_sequence_id++);
  request.set_table_name(desc.TableName());
  request.set_user_token(
      GetUserToken(client_options_.user_identity, client_options_.user_passcode));

  access_builder_->BuildRequest(&request);

  TableSchema* schema = request.mutable_schema();
  TableDescToSchema(desc, schema);

  ErrorCode err2;
  TableDescriptor* old_desc = GetTableDescriptor(desc.TableName(), &err2);
  if (old_desc == NULL) {
    return false;
  }
  TableSchema old_schema;
  TableDescToSchema(*old_desc, &old_schema);
  delete old_desc;

  // if try to update lg, need to disable table
  bool is_update_lg = IsSchemaLgDiff(*schema, old_schema);
  bool is_update_cf = IsSchemaCfDiff(*schema, old_schema);

  // compatible for old-master which no support for online-schema-update
  if (!FLAGS_tera_online_schema_update_enabled && IsTableEnabled(desc.TableName(), err) &&
      (is_update_lg || is_update_cf)) {
    err->SetFailed(ErrorCode::kBadParam,
                   "disable this table if you want to update (Lg | Cf) property(ies)");
    return false;
  }

  string reason;
  if (master_client.UpdateTable(&request, &response)) {
    if (CheckReturnValue(response.status(), reason, err)) {
      return true;
    }
    LOG(ERROR) << reason << "| status: " << StatusCodeToString(response.status());
  } else {
    reason = "rpc fail to update table:" + desc.TableName();
    LOG(ERROR) << reason;
    err->SetFailed(ErrorCode::kSystem, reason);
  }
  return false;
}

bool ClientImpl::UpdateCheck(const std::string& table_name, bool* done, ErrorCode* err) {
  master::MasterClient master_client(cluster_->MasterAddr());