From edf33115e4f8cdd993155da1677094c76b0544fd Mon Sep 17 00:00:00 2001 From: Xu Peng Date: Mon, 27 May 2019 18:41:33 +0800 Subject: [PATCH] refactor(db): UpdateTableFiles Former-commit-id: 749cfe1d229a7f2edadd3cd913b96e0087be9cc5 --- cpp/src/db/DBImpl.cpp | 4 ++-- cpp/src/db/DBMetaImpl.cpp | 2 +- cpp/src/db/DBMetaImpl.h | 2 +- cpp/src/db/Meta.h | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/cpp/src/db/DBImpl.cpp b/cpp/src/db/DBImpl.cpp index 6e0df688..f71afbd0 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 5ccc2d9f..ad2a7001 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 813b07c2..d7c05782 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 15d9b0e5..d7f0797c 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, -- GitLab