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

Update BlockStreamProfileInfo

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-02-18 16:16:30 +03:00
parent 145cb6e12f
commit 49926098d3
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dbms/src/DataStreams/BlockStreamProfileInfo.cpp
View File

@ -122,6 +122,7 @@ void BlockStreamProfileInfo::calculateRowsBeforeLimit() const
/// Then the data about `rows_before_limit` can be in `RemoteBlockInputStream` (come from a remote server).
BlockStreamProfileInfos remotes;
collectInfosForStreamsWithName("Remote", remotes);
collectInfosForStreamsWithName("TreeExecutor", remotes);
if (remotes.empty())
return;

2
dbms/src/Processors/Executors/TreeExecutorBlockInputStream.h
View File

@ -34,7 +34,7 @@ public:
init();
}
String getName() const override { return root->getName(); }
String getName() const override { return "TreeExecutor"; }
Block getHeader() const override { return root->getOutputs().front().getHeader(); }
/// This methods does not affect TreeExecutor as IBlockInputStream itself.