From c8355a19061baeb8c3bde242f6568467d6dba5cd Mon Sep 17 00:00:00 2001 From: Bingyi Sun Date: Thu, 2 Nov 2023 16:04:05 +0800 Subject: [PATCH] [Cpp] Create blob directory in Open (#86) Signed-off-by: sunby --- cpp/include/milvus-storage/common/utils.h | 2 +- cpp/src/common/utils.cpp | 2 +- cpp/src/storage/space.cpp | 1 + 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/cpp/include/milvus-storage/common/utils.h b/cpp/include/milvus-storage/common/utils.h index 21b04aa..ae948b1 100644 --- a/cpp/include/milvus-storage/common/utils.h +++ b/cpp/include/milvus-storage/common/utils.h @@ -27,7 +27,7 @@ std::string GetManifestDir(const std::string& path); std::string GetScalarDataDir(const std::string& path); std::string GetVectorDataDir(const std::string& path); std::string GetDeleteDataDir(const std::string& path); -std::string GetBolbDir(const std::string& path); +std::string GetBlobDir(const std::string& path); std::string GetNewBlobFilePath(const std::string& path); } // namespace milvus_storage diff --git a/cpp/src/common/utils.cpp b/cpp/src/common/utils.cpp index 880187c..62e5974 100644 --- a/cpp/src/common/utils.cpp +++ b/cpp/src/common/utils.cpp @@ -250,7 +250,7 @@ std::string GetManifestTmpFilePath(const std::string& path, const int64_t versio return arrow::fs::internal::JoinAbstractPath( std::vector{path, kManifestsDir, std::to_string(version) + kManifestTempFileSuffix}); } -std::string GetBolbDir(const std::string& path) { +std::string GetBlobDir(const std::string& path) { return arrow::fs::internal::JoinAbstractPath(std::vector{path, kBlobDir}); } diff --git a/cpp/src/storage/space.cpp b/cpp/src/storage/space.cpp index 8b04021..f517420 100644 --- a/cpp/src/storage/space.cpp +++ b/cpp/src/storage/space.cpp @@ -239,6 +239,7 @@ Result> Space::Open(const std::string& uri, Options optio RETURN_ARROW_NOT_OK(fs->CreateDir(GetScalarDataDir(path))); RETURN_ARROW_NOT_OK(fs->CreateDir(GetVectorDataDir(path))); RETURN_ARROW_NOT_OK(fs->CreateDir(GetDeleteDataDir(path))); + RETURN_ARROW_NOT_OK(fs->CreateDir(GetBlobDir(path))); ASSIGN_OR_RETURN_NOT_OK(auto info_vec, FindAllManifest(fs, path)); if (info_vec.empty()) {