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

Removed dynamic_cast from PipelineExecutor.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-09-11 20:06:06 +03:00
parent 9916be2800
commit 95abc1f910
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/Processors/Executors/PipelineExecutor.cpp
View File

@ -584,7 +584,7 @@ void PipelineExecutor::executeSingleThread(size_t thread_num, size_t num_threads
queue.pop();
auto stream = task->processor->getStream();
if (stream != IProcessor::NO_STREAM && dynamic_cast<const ISource *>(task->processor))
if (stream != IProcessor::NO_STREAM)
{
bool found_in_queue = false;
auto thread_to_wake = stream % num_threads;

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

@ -116,7 +116,7 @@ void QueryPipeline::addSimpleTransformImpl(const TProcessorGetter & getter)
Block header;
auto add_transform = [&](OutputPort *& stream, StreamType stream_type, size_t stream_num = IProcessor::NO_STREAM)
auto add_transform = [&](OutputPort *& stream, StreamType stream_type, size_t stream_num [[maybe_unused]] = IProcessor::NO_STREAM)
{
if (!stream)
return;
@ -149,8 +149,8 @@ void QueryPipeline::addSimpleTransformImpl(const TProcessorGetter & getter)
if (transform)
{
if (stream_type == StreamType::Main)
transform->setStream(stream_num);
// if (stream_type == StreamType::Main)
// transform->setStream(stream_num);
connect(*stream, transform->getInputs().front());
stream = &transform->getOutputs().front();