thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-18 21:51:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

added IColumn::select

Browse Source
This commit is contained in:
Nikolai Kochetov 2018-05-03 16:45:11 +03:00
parent ce3b588de0
commit 0806b957aa
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
dbms/src/DataTypes/DataTypeWithDictionary.h
View File

@ -75,7 +75,10 @@ public:
path.push_back(Substream::DictionaryElements);
if (auto stream = getter(path))
dictionary_type->serializeBinaryBulk(*column_with_dictionary.getUnique()->getNestedColumn(), *stream, offset, limit);
{
if (offset == 0)
dictionary_type->serializeBinaryBulk(*column_with_dictionary.getUnique()->getNestedColumn(), *stream, 0, 0);
}
path.back() = Substream::DictionaryIndexes;
if (auto stream = getter(path))
@ -94,7 +97,16 @@ public:
path.push_back(Substream::DictionaryElements);
if (ReadBuffer * stream = getter(path))
dictionary_type->deserializeBinaryBulk(*column_with_dictionary.getUnique()->getNestedColumn(), *stream, limit, 0);
{
if (column.empty())
{
auto dict_column = column_with_dictionary.getUnique()->getNestedColumn()->cloneEmpty();
dictionary_type->deserializeBinaryBulk(*dict_column, *stream, 0, 0);
/// Note: it's assumed that rows inserted into columnUnique get incremental indexes.
column_with_dictionary.getUnique()->uniqueInsertRangeFrom(*dict_column, 0, dict_column->size());
}
}
path.back() = Substream::DictionaryIndexes;
if (auto stream = getter(path))