thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-28 02:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing cache for sets.

Browse Source
This commit is contained in:
Nikolai Kochetov 2023-06-12 18:59:07 +00:00
parent eb16745033
commit 7025232175
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Processors/Transforms/CreatingSetsTransform.cpp
View File

@ -86,7 +86,7 @@ void CreatingSetsTransform::startSubquery()
} }
} }
if (subquery.set) if (subquery.set && !set_from_cache)
LOG_TRACE(log, "Creating set, key: {}", subquery.key); LOG_TRACE(log, "Creating set, key: {}", subquery.key);
if (subquery.table) if (subquery.table)
LOG_TRACE(log, "Filling temporary table."); LOG_TRACE(log, "Filling temporary table.");
@ -97,7 +97,7 @@ void CreatingSetsTransform::startSubquery()
/// TODO: make via port /// TODO: make via port
table_out = QueryPipeline(subquery.table->write({}, subquery.table->getInMemoryMetadataPtr(), nullptr, /*async_insert=*/false)); table_out = QueryPipeline(subquery.table->write({}, subquery.table->getInMemoryMetadataPtr(), nullptr, /*async_insert=*/false));
done_with_set = !subquery.set; done_with_set = !subquery.set || set_from_cache;
done_with_table = !subquery.table; done_with_table = !subquery.table;
if ((done_with_set && !set_from_cache) /*&& done_with_join*/ && done_with_table) if ((done_with_set && !set_from_cache) /*&& done_with_join*/ && done_with_table)
@ -175,10 +175,10 @@ void CreatingSetsTransform::consume(Chunk chunk)
Chunk CreatingSetsTransform::generate() Chunk CreatingSetsTransform::generate()
{ {
if (subquery.set) if (subquery.set && !set_from_cache)
{ {
subquery.set->finishInsert(); subquery.set->finishInsert();
subquery.promise_to_fill_set.set_value(subquery.set); //subquery.promise_to_fill_set.set_value(subquery.set);
if (promise_to_build) if (promise_to_build)
promise_to_build->set_value(subquery.set); promise_to_build->set_value(subquery.set);
} }