admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-03 01:12:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(db): UpdateTableFiles

Browse Source 
Former-commit-id: 749cfe1d229a7f2edadd3cd913b96e0087be9cc5
This commit is contained in:
Xu Peng 2019-05-27 18:41:33 +08:00
parent ec4e83db3f
commit edf33115e4
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cpp/src/db/DBImpl.cpp
View File

@ -280,7 +280,7 @@ Status DBImpl<EngineT>::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<EngineT>::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"

2
cpp/src/db/DBMetaImpl.cpp
View File

@ -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) {

2
cpp/src/db/DBMetaImpl.h
View File

@ -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;

2
cpp/src/db/Meta.h
View File

@ -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,