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

dbms: fixed error with CollapsingSortedBlockInputStream [#CONV-2944].

Browse Source
This commit is contained in:
Alexey Milovidov 2013-01-10 17:12:14 +00:00
parent bf9d7c4127
commit 9485dd6fbe
2 changed files with 92 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/src/DataStreams/CollapsingSortedBlockInputStream.cpp
View File

@ -94,6 +94,8 @@ Block CollapsingSortedBlockInputStream::readImpl()
insertRows(merged_columns, merged_rows);
current_key = next_key;
next_key.resize(description.size());
count_negative = 0;
count_positive = 0;
}

90
dbms/src/DataStreams/tests/collapsing_sorted_stream.cpp Normal file
View File

@ -0,0 +1,90 @@
#include <iostream>
#include <iomanip>
#include <Poco/SharedPtr.h>
#include <Poco/Stopwatch.h>
#include <Poco/NumberParser.h>
#include <DB/IO/WriteBufferFromFileDescriptor.h>
#include <DB/DataStreams/OneBlockInputStream.h>
#include <DB/DataStreams/CollapsingSortedBlockInputStream.h>
#include <DB/DataStreams/FormatFactory.h>
#include <DB/DataStreams/copyData.h>
#include <DB/DataTypes/DataTypesNumberFixed.h>
using Poco::SharedPtr;
int main(int argc, char ** argv)
{
using namespace DB;
try
{
Block block1;
{
ColumnWithNameAndType column1;
column1.name = "Sign";
column1.type = new DataTypeInt8;
column1.column = new ColumnInt8;
column1.column->insert(DB::Int64(1));
block1.insert(column1);
ColumnWithNameAndType column2;
column2.name = "CounterID";
column2.type = new DataTypeUInt32;
column2.column = new ColumnUInt32;
column2.column->insert(DB::UInt64(123));
block1.insert(column2);
}
Block block2;
{
ColumnWithNameAndType column1;
column1.name = "Sign";
column1.type = new DataTypeInt8;
column1.column = new ColumnInt8;
column1.column->insert(DB::Int64(1));
block2.insert(column1);
ColumnWithNameAndType column2;
column2.name = "CounterID";
column2.type = new DataTypeUInt32;
column2.column = new ColumnUInt32;
column2.column->insert(DB::UInt64(456));
block2.insert(column2);
}
BlockInputStreams inputs;
inputs.push_back(new OneBlockInputStream(block1));
inputs.push_back(new OneBlockInputStream(block2));
SortDescription descr;
SortColumnDescription col_descr("CounterID", 1);
descr.push_back(col_descr);
CollapsingSortedBlockInputStream collapsed(inputs, descr, "Sign", 1048576);
std::cerr << std::endl << "!!!!!!!!!!!!!!!!!!!!" << std::endl << std::endl;
Block res = collapsed.read();
std::cerr << std::endl << "!!!!!!!!!!!!!!!!!!!!" << std::endl << std::endl;
/* FormatFactory formats;
WriteBufferFromFileDescriptor out_buf(STDERR_FILENO);
BlockOutputStreamPtr output = formats.getOutput("TabSeparated", out_buf, block1);
copyData(collapsed, *output);*/
}
catch (const Exception & e)
{
std::cerr << e.what() << ", " << e.displayText() << std::endl;
return 1;
}
return 0;
}