Use v3 collection serialization inside UDTs

This commit is contained in:
Tyler Hobbs
2014-05-28 17:59:55 -05:00
parent 50f8aa7f0a
commit 09ea6030d9

View File

@@ -800,7 +800,9 @@ class UserDefinedType(_ParameterizedType):
p += cls.FIELD_LENGTH
item = byts[p:p + itemlen]
p += itemlen
result.append(col_type.from_binary(item, protocol_version))
# collections inside UDTs are always encoded with at least the
# version 3 format
result.append(col_type.from_binary(item, max(3, protocol_version)))
if len(result) < len(cls.subtypes):
nones = [None] * (len(cls.subtypes) - len(result))