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

Update FormatFactory.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-07-31 16:26:08 +03:00
parent 2c638d577d
commit 4e38a45922
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dbms/src/Formats/FormatFactory.cpp
View File

@ -8,6 +8,7 @@
#include <Processors/Formats/InputStreamFromInputFormat.h> #include <Processors/Formats/InputStreamFromInputFormat.h>
#include <Processors/Formats/OutputStreamToOutputFormat.h> #include <Processors/Formats/OutputStreamToOutputFormat.h>
#include <DataStreams/SquashingBlockOutputStream.h> #include <DataStreams/SquashingBlockOutputStream.h>
#include <DataStreams/NativeBlockInputStream.h>
namespace DB namespace DB
@ -84,6 +85,9 @@ BlockInputStreamPtr FormatFactory::getInput(
UInt64 rows_portion_size, UInt64 rows_portion_size,
ReadCallback callback) const ReadCallback callback) const
{ {
if (name == "Native")
return std::make_shared<NativeBlockInputStream>(buf, sample, 0);
auto format = getInputFormat(name, buf, sample, context, max_block_size, rows_portion_size, std::move(callback)); auto format = getInputFormat(name, buf, sample, context, max_block_size, rows_portion_size, std::move(callback));
return std::make_shared<InputStreamFromInputFormat>(std::move(format)); return std::make_shared<InputStreamFromInputFormat>(std::move(format));
} }