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

remove useless code

Browse Source
This commit is contained in:
taiyang-li 2022-01-10 19:17:12 +08:00
parent 7c7f45bce2
commit 2cae8d552c
4 changed files with 0 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -681,13 +681,6 @@ void IMergeTreeDataPart::appendFilesOfColumnsChecksumsIndexes(Strings & files, b
} }
} }
size_t IMergeTreeDataPart::fileNumberOfColumnsChecksumsIndexes() const
{
Strings files;
appendFilesOfColumnsChecksumsIndexes(files, true);
return files.size();
}
void IMergeTreeDataPart::loadProjections(bool require_columns_checksums, bool check_consistency) void IMergeTreeDataPart::loadProjections(bool require_columns_checksums, bool check_consistency)
{ {
auto metadata_snapshot = storage.getInMemoryMetadataPtr(); auto metadata_snapshot = storage.getInMemoryMetadataPtr();

1
src/Storages/MergeTree/IMergeTreeDataPart.h
View File

@ -149,7 +149,6 @@ public:
/// Load checksums from checksums.txt if exists. Load index if required. /// Load checksums from checksums.txt if exists. Load index if required.
void loadColumnsChecksumsIndexes(bool require_columns_checksums, bool check_consistency); void loadColumnsChecksumsIndexes(bool require_columns_checksums, bool check_consistency);
void appendFilesOfColumnsChecksumsIndexes(Strings & files, bool include_projection = false) const; void appendFilesOfColumnsChecksumsIndexes(Strings & files, bool include_projection = false) const;
size_t fileNumberOfColumnsChecksumsIndexes() const;
String getMarksFileExtension() const { return index_granularity_info.marks_file_extension; } String getMarksFileExtension() const { return index_granularity_info.marks_file_extension; }

9
src/Storages/MergeTree/MergeTreeData.cpp
View File

@ -1341,15 +1341,6 @@ void MergeTreeData::loadDataParts(bool skip_sanity_checks)
LOG_DEBUG(log, "Loaded data parts ({} items)", data_parts_indexes.size()); LOG_DEBUG(log, "Loaded data parts ({} items)", data_parts_indexes.size());
} }
size_t MergeTreeData::fileNumberOfDataParts(const DataPartStates & states) const
{
size_t result = 0;
auto parts = getDataParts(states);
for (const auto & part : parts)
result += part->fileNumberOfColumnsChecksumsIndexes();
return result;
}
/// Is the part directory old. /// Is the part directory old.
/// True if its modification time and the modification time of all files inside it is less then threshold. /// True if its modification time and the modification time of all files inside it is less then threshold.
/// (Only files on the first level of nesting are considered). /// (Only files on the first level of nesting are considered).

2
src/Storages/MergeTree/MergeTreeData.h
View File

@ -427,8 +427,6 @@ public:
/// Load the set of data parts from disk. Call once - immediately after the object is created. /// Load the set of data parts from disk. Call once - immediately after the object is created.
void loadDataParts(bool skip_sanity_checks); void loadDataParts(bool skip_sanity_checks);
size_t fileNumberOfDataParts(const DataPartStates & states) const;
String getLogName() const { return log_name; } String getLogName() const { return log_name; }
Int64 getMaxBlockNumber() const; Int64 getMaxBlockNumber() const;