From 25f0f2f2d1965d5498026e247adb40564750bb8e Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Fri, 4 May 2018 21:54:58 +0300 Subject: [PATCH] added DataTypeWithDictionary serialization per granule --- dbms/src/DataTypes/DataTypeWithDictionary.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dbms/src/DataTypes/DataTypeWithDictionary.cpp b/dbms/src/DataTypes/DataTypeWithDictionary.cpp index 77164cdc522..724f40ec41d 100644 --- a/dbms/src/DataTypes/DataTypeWithDictionary.cpp +++ b/dbms/src/DataTypes/DataTypeWithDictionary.cpp @@ -78,8 +78,8 @@ void DataTypeWithDictionary::serializeBinaryBulkWithMultipleStreams( bool full_column = offset == 0 && limit >= indexes->size(); - auto unique_indexes = getUniqueIndex(full_column ? indexes : indexes->cut(offset, limit)); - auto used_keys = keys->index(*unique_indexes, 0); + ColumnPtr unique_indexes = getUniqueIndex(full_column ? indexes : indexes->cut(offset, limit)); + auto used_keys = keys->index(unique_indexes, 0); UInt64 used_keys_size = used_keys->size(); writeIntBinary(used_keys_size, *stream); @@ -122,7 +122,7 @@ void DataTypeWithDictionary::deserializeBinaryBulkWithMultipleStreams( auto index_col = indexes_type->createColumn(); indexes_type->deserializeBinaryBulk(*index_col, *stream, limit, 0); - column_with_dictionary.getIndexes()->insertRangeFrom(*index_col->index(indexes), 0, limit); + column_with_dictionary.getIndexes()->insertRangeFrom(*index_col->index(indexes, 0), 0, limit); } }