thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

More resize

Browse Source
This commit is contained in:
Amos Bird 2020-10-13 09:56:35 +08:00
parent 47fcd8bffb
commit ca7a5ccd0d
No known key found for this signature in database
GPG Key ID: 80D430DCBECFEDB4
3 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Processors/Sources/DelayedSource.cpp
View File

@ -122,8 +122,7 @@ void DelayedSource::work()
return;
}
if (pipe.numOutputPorts() > 1)
pipe.addTransform(std::make_shared<ResizeProcessor>(header, pipe.numOutputPorts(), 1));
pipe.resize(1);
main_output = pipe.getOutputPort(0);
totals_output = pipe.getTotalsPort();

2
src/Processors/Transforms/MergingAggregatedMemoryEfficientTransform.cpp
View File

@ -511,7 +511,7 @@ void addMergingAggregatedMemoryEfficientTransform(
/// --> GroupingAggregated --> ResizeProcessor --> MergingAggregatedBucket --> SortingAggregated -->
/// --> --> MergingAggregatedBucket -->
pipe.addTransform(std::make_shared<ResizeProcessor>(Block(), 1, num_merging_processors));
pipe.resize(num_merging_processors);
pipe.addSimpleTransform([params](const Block &)
{

1
src/Storages/StorageMemory.h
View File

@ -21,7 +21,6 @@ namespace DB
*/
class StorageMemory final : public ext::shared_ptr_helper<StorageMemory>, public IStorage
{
friend class MemoryBlockInputStream;
friend class MemoryBlockOutputStream;
friend struct ext::shared_ptr_helper<StorageMemory>;