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

Update QueryPipeline.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-10-04 20:46:48 +03:00
parent 23069ca6d0
commit d4f11af817
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dbms/src/Processors/QueryPipeline.cpp
View File

@ -515,8 +515,8 @@ void QueryPipeline::setProgressCallback(const ProgressCallback & callback)
{
for (auto & processor : processors)
{
if (auto * source = typeid_cast<SourceFromInputStream *>(processor.get()))
source->getStream().setProgressCallback(callback);
if (auto * source = typeid_cast<ISourceWithProgress *>(processor.get()))
source->setProgressCallback(callback);
if (auto * source = typeid_cast<CreatingSetsTransform *>(processor.get()))
source->setProgressCallback(callback);
@ -527,8 +527,8 @@ void QueryPipeline::setProcessListElement(QueryStatus * elem)
{
for (auto & processor : processors)
{
if (auto * source = typeid_cast<SourceFromInputStream *>(processor.get()))
source->getStream().setProcessListElement(elem);
if (auto * source = dynamic_cast<ISourceWithProgress *>(processor.get()))
source->setProcessListElement(elem);
if (auto * source = typeid_cast<CreatingSetsTransform *>(processor.get()))
source->setProcessListElement(elem);