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

fix code style

Browse Source
This commit is contained in:
fuqi 2021-04-18 18:05:18 +08:00
parent 31f2c65e4f
commit 9f4c6adb43
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Storages/StorageJoin.cpp
View File

@ -82,7 +82,7 @@ void StorageJoin::truncate(
void StorageJoin::checkMutationIsPossible(const MutationCommands & commands, const Settings & /* settings */) const void StorageJoin::checkMutationIsPossible(const MutationCommands & commands, const Settings & /* settings */) const
{ {
for(const auto& command: commands) { for (const auto & command: commands) {
switch (command.type) { switch (command.type) {
case MutationCommand::Type::DELETE: case MutationCommand::Type::DELETE:
break; break;
@ -129,7 +129,7 @@ void StorageJoin::mutate(const MutationCommands & commands, ContextPtr context)
std::vector<std::string> files; std::vector<std::string> files;
disk->listFiles(path, files); disk->listFiles(path, files);
for (const auto& file_name: files) { for (const auto & file_name: files) {
if (file_name.ends_with(".bin")) { if (file_name.ends_with(".bin")) {
disk->removeFileIfExists(path + file_name); disk->removeFileIfExists(path + file_name);
} }
@ -164,7 +164,8 @@ HashJoinPtr StorageJoin::getJoinLocked(std::shared_ptr<TableJoin> analyzed_join)
void StorageJoin::insertBlock(const Block & block) void StorageJoin::insertBlock(const Block & block)
{std::unique_lock<std::shared_mutex> lock(rwlock); {
std::unique_lock<std::shared_mutex> lock(rwlock);
join->addJoinedBlock(block, true); join->addJoinedBlock(block, true);
} }