thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-26 19:50:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added method "getHeader" in IBlockOutputStream: development [#CLICKHOUSE-2]

Browse Source
This commit is contained in:
Alexey Milovidov 2018-02-19 21:15:30 +03:00
parent 7ff1346685
commit 3b550789b0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/Storages/StorageDistributed.cpp
View File

@ -1,4 +1,5 @@
#include <DataStreams/OneBlockInputStream.h>
#include <DataStreams/materializeBlock.h>
#include <Databases/IDatabase.h>
@ -195,8 +196,8 @@ BlockInputStreams StorageDistributed::read(
if (settings.global_subqueries_method == GlobalSubqueriesMethod::PUSH)
external_tables = context.getExternalTables();
Block header = InterpreterSelectQuery(query_info.query, context, processed_stage, 0,
std::make_shared<OneBlockInputStream>(getSampleBlockForColumns(column_names))).execute().in->getHeader();
Block header = materializeBlock(InterpreterSelectQuery(query_info.query, context, processed_stage, 0,
std::make_shared<OneBlockInputStream>(getSampleBlockForColumns(column_names))).execute().in->getHeader());
ClusterProxy::SelectStreamFactory select_stream_factory(
header, processed_stage, QualifiedTableName{remote_database, remote_table}, external_tables);