From 5e6d105fd5398ab8aacb2cb91e225eacb36b3e8c Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Fri, 4 May 2018 22:19:12 +0300 Subject: [PATCH] added DataTypeWithDictionary serialization per granule --- dbms/src/DataTypes/DataTypeWithDictionary.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dbms/src/DataTypes/DataTypeWithDictionary.cpp b/dbms/src/DataTypes/DataTypeWithDictionary.cpp index c2f25349e3d..6b415da9442 100644 --- a/dbms/src/DataTypes/DataTypeWithDictionary.cpp +++ b/dbms/src/DataTypes/DataTypeWithDictionary.cpp @@ -83,7 +83,7 @@ void DataTypeWithDictionary::serializeBinaryBulkWithMultipleStreams( UInt64 used_keys_size = used_keys->size(); writeIntBinary(used_keys_size, *stream); - dictionary_type->serializeBinaryBulkWithMultipleStreams(*keys, getter, 0, 0, + dictionary_type->serializeBinaryBulkWithMultipleStreams(*used_keys, getter, 0, 0, position_independent_encoding, path); } path.back() = Substream::DictionaryIndexes; @@ -111,7 +111,7 @@ void DataTypeWithDictionary::deserializeBinaryBulkWithMultipleStreams( readIntBinary(num_keys, *stream); auto dict_column = column_with_dictionary.getUnique()->getNestedColumn()->cloneEmpty(); dictionary_type->deserializeBinaryBulkWithMultipleStreams(*dict_column, getter, num_keys, 0, position_independent_encoding, path); - indexes = column_with_dictionary.getUnique()->uniqueInsertRangeFrom(*dict_column, 0, dict_column->size()); + indexes = column_with_dictionary.getUnique()->uniqueInsertRangeFrom(*dict_column, 0, num_keys); } path.back() = Substream::DictionaryIndexes;