added DataTypeWithDictionary serialization per granule

This commit is contained in:
Nikolai Kochetov 2018-05-04 21:54:58 +03:00
parent 310931a8a5
commit 25f0f2f2d1

View File

@ -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);
}
}