diff --git a/cpp/src/db/DBImpl.cpp b/cpp/src/db/DBImpl.cpp index 6e0df688b9df12dc091c807995ced3587ecbd980..f71afbd02f2e23b52ce2c8403710f1b4dd6d5bb9 100644 --- a/cpp/src/db/DBImpl.cpp +++ b/cpp/src/db/DBImpl.cpp @@ -280,7 +280,7 @@ Status DBImpl::merge_files(const std::string& table_id, const meta::Dat } table_file.size = index_size; updated.push_back(table_file); - status = _pMeta->update_files(updated); + status = _pMeta->UpdateTableFiles(updated); LOG(DEBUG) << "New merged file " << table_file.file_id << " of size=" << index.PhysicalSize()/(1024*1024) << " M"; @@ -343,7 +343,7 @@ Status DBImpl::build_index(const meta::TableFileSchema& file) { to_remove.file_type = meta::TableFileSchema::TO_DELETE; meta::TableFilesSchema update_files = {to_remove, table_file}; - _pMeta->update_files(update_files); + _pMeta->UpdateTableFiles(update_files); LOG(DEBUG) << "New index file " << table_file.file_id << " of size " << index->PhysicalSize()/(1024*1024) << " M" diff --git a/cpp/src/db/DBMetaImpl.cpp b/cpp/src/db/DBMetaImpl.cpp index 5ccc2d9f4ab8a02ab081fc9267491d27b63b8ace..ad2a700115428e69eb6b93ab84e0846729debb40 100644 --- a/cpp/src/db/DBMetaImpl.cpp +++ b/cpp/src/db/DBMetaImpl.cpp @@ -550,7 +550,7 @@ Status DBMetaImpl::UpdateTableFile(TableFileSchema& file_schema) { return Status::OK(); } -Status DBMetaImpl::update_files(TableFilesSchema& files) { +Status DBMetaImpl::UpdateTableFiles(TableFilesSchema& files) { try { auto commited = ConnectorPtr->transaction([&] () mutable { for (auto& file : files) { diff --git a/cpp/src/db/DBMetaImpl.h b/cpp/src/db/DBMetaImpl.h index 813b07c20f979f0a9bf2f20169dc596411c5b1f0..d7c057828f531b90dd8cc913dc12cc5cac5244a5 100644 --- a/cpp/src/db/DBMetaImpl.h +++ b/cpp/src/db/DBMetaImpl.h @@ -31,7 +31,7 @@ public: virtual Status UpdateTableFile(TableFileSchema& file_schema) override; - virtual Status update_files(TableFilesSchema& files) override; + virtual Status UpdateTableFiles(TableFilesSchema& files) override; virtual Status files_to_merge(const std::string& table_id, DatePartionedTableFilesSchema& files) override; diff --git a/cpp/src/db/Meta.h b/cpp/src/db/Meta.h index 15d9b0e575159459e15687a123c205ba83802a98..d7f0797cf6cc5ceee4318d995a941a6849347070 100644 --- a/cpp/src/db/Meta.h +++ b/cpp/src/db/Meta.h @@ -33,7 +33,7 @@ public: virtual Status GetTableFile(TableFileSchema& file_schema) = 0; virtual Status UpdateTableFile(TableFileSchema& file_schema) = 0; - virtual Status update_files(TableFilesSchema& files) = 0; + virtual Status UpdateTableFiles(TableFilesSchema& files) = 0; virtual Status files_to_search(const std::string& table_id, const DatesT& partition,