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

add readPrefix()/readSuffix() calls for completeness #2084 [#CLICKHOUSE-3540]

Browse Source
This commit is contained in:
Alex Zatelepin 2018-03-27 22:25:50 +00:00
parent 88a9b7de91
commit 1be7c09702
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/DataStreams/PushingToViewsBlockOutputStream.cpp
View File

@ -74,8 +74,13 @@ void PushingToViewsBlockOutputStream::write(const Block & block)
BlockInputStreamPtr from = std::make_shared<OneBlockInputStream>(block);
InterpreterSelectQuery select(view.query, *views_context, {}, QueryProcessingStage::Complete, 0, from);
BlockInputStreamPtr data = std::make_shared<MaterializingBlockInputStream>(select.execute().in);
data->readPrefix();
while (Block result_block = data->read())
view.out->write(result_block);
data->readSuffix();
}
catch (Exception & ex)
{