This commit is contained in:
kssenii 2022-08-31 15:39:53 +02:00
parent ebcc022782
commit 3a183236a2
2 changed files with 10 additions and 0 deletions

View File

@ -55,6 +55,14 @@ MergeTreeMarksLoader::MergeTreeMarksLoader(
}
}
MergeTreeMarksLoader::~MergeTreeMarksLoader()
{
if (future.valid())
{
future.wait();
}
}
const MarkInCompressedFile & MergeTreeMarksLoader::getMark(size_t row_index, size_t column_index)
{
if (!marks)

View File

@ -26,6 +26,8 @@ public:
ThreadPool * load_marks_threadpool_,
size_t columns_in_mark_ = 1);
~MergeTreeMarksLoader();
const MarkInCompressedFile & getMark(size_t row_index, size_t column_index = 0);
private: