Skip to content

Commit

Permalink
[Cpp] Create blob directory in Open (#86)
Browse files Browse the repository at this point in the history
Signed-off-by: sunby <[email protected]>
  • Loading branch information
sunby committed Nov 2, 2023
1 parent eeb09fe commit c8355a1
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion cpp/include/milvus-storage/common/utils.h
Original file line number Diff line number Diff line change
Expand Up @@ -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
2 changes: 1 addition & 1 deletion cpp/src/common/utils.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -250,7 +250,7 @@ std::string GetManifestTmpFilePath(const std::string& path, const int64_t versio
return arrow::fs::internal::JoinAbstractPath(
std::vector<std::string_view>{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<std::string_view>{path, kBlobDir});
}

Expand Down
1 change: 1 addition & 0 deletions cpp/src/storage/space.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -239,6 +239,7 @@ Result<std::unique_ptr<Space>> 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()) {
Expand Down

0 comments on commit c8355a1

Please sign in to comment.