thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 12:32:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Default codec if part is not stored on disk

Browse Source
This commit is contained in:
alesapin 2020-08-27 16:32:23 +03:00
parent 0ff5e5412e
commit d426751e26
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/Storages/MergeTree/IMergeTreeDataPart.cpp
View File

@ -486,7 +486,10 @@ bool IMergeTreeDataPart::loadDefaultCompressionCodec()
{ {
/// In memory parts doesn't have any compression /// In memory parts doesn't have any compression
if (!isStoredOnDisk()) if (!isStoredOnDisk())
{
default_codec = CompressionCodecFactory::instance().get("NONE", {});
return true; return true;
}
String path = getFullRelativePath() + DEFAULT_COMPRESSION_CODEC_FILE_NAME; String path = getFullRelativePath() + DEFAULT_COMPRESSION_CODEC_FILE_NAME;
if (!volume->getDisk()->exists(path)) if (!volume->getDisk()->exists(path))
@ -522,9 +525,13 @@ bool IMergeTreeDataPart::loadDefaultCompressionCodec()
void IMergeTreeDataPart::detectAndSetDefaultCompressionCodec(size_t total_storage_size) void IMergeTreeDataPart::detectAndSetDefaultCompressionCodec(size_t total_storage_size)
{ {
default_codec = storage.global_context.chooseCompressionCodec( /// In memory parts doesn't have any compression
getBytesOnDisk(), if (isStoredOnDisk())
static_cast<double>(getBytesOnDisk()) / total_storage_size); default_codec
= storage.global_context.chooseCompressionCodec(getBytesOnDisk(),
static_cast<double>(getBytesOnDisk()) / total_storage_size);
else
default_codec = CompressionCodecFactory::instance().get("NONE", {});
} }
void IMergeTreeDataPart::loadPartitionAndMinMaxIndex() void IMergeTreeDataPart::loadPartitionAndMinMaxIndex()