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

Fixed build [#METR-2944].

Browse Source
This commit is contained in:
Alexey Milovidov 2015-01-25 11:09:25 +03:00
parent 6927823716
commit e8f9083f07
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
dbms/src/DataStreams/tests/native_streams.cpp
View File

@ -6,8 +6,10 @@
#include <Poco/Stopwatch.h> #include <Poco/Stopwatch.h>
#include <Poco/SharedPtr.h> #include <Poco/SharedPtr.h>
#include <DB/IO/ReadBufferFromIStream.h> #include <DB/IO/ReadBufferFromFileDescriptor.h>
#include <DB/IO/WriteBufferFromOStream.h> #include <DB/IO/WriteBufferFromFileDescriptor.h>
#include <DB/IO/CompressedReadBuffer.h>
#include <DB/IO/CompressedWriteBuffer.h>
#include <DB/DataTypes/DataTypesNumberFixed.h> #include <DB/DataTypes/DataTypesNumberFixed.h>
#include <DB/DataTypes/DataTypeString.h> #include <DB/DataTypes/DataTypeString.h>
@ -106,7 +108,7 @@ int main(int argc, char ** argv)
{ {
QueryProcessingStage::Enum stage; QueryProcessingStage::Enum stage;
SharedPtr<IBlockInputStream> in = table->read(column_names, 0, Context{}, Settings(), stage)[0]; SharedPtr<IBlockInputStream> in = table->read(column_names, 0, Context{}, Settings(), stage)[0];
WriteBufferFromOStream out1(std::cout); WriteBufferFromFileDescriptor out1(STDOUT_FILENO);
CompressedWriteBuffer out2(out1); CompressedWriteBuffer out2(out1);
NativeBlockOutputStream out3(out2, Revision::get()); NativeBlockOutputStream out3(out2, Revision::get());
copyData(*in, out3); copyData(*in, out3);
@ -117,7 +119,7 @@ int main(int argc, char ** argv)
{ {
DataTypeFactory factory; DataTypeFactory factory;
ReadBufferFromIStream in1(std::cin); ReadBufferFromFileDescriptor in1(STDIN_FILENO);
CompressedReadBuffer in2(in1); CompressedReadBuffer in2(in1);
NativeBlockInputStream in3(in2, factory, Revision::get()); NativeBlockInputStream in3(in2, factory, Revision::get());
SharedPtr<IBlockOutputStream> out = table->write(0); SharedPtr<IBlockOutputStream> out = table->write(0);