@Test public void testListUUIDType() { List<UUID> originalList = new ArrayList<>(); UUID uuid1 = UUID.randomUUID(); UUID uuid2 = UUID.randomUUID(); UUID uuid3 = UUID.randomUUID(); originalList.add(uuid1); originalList.add(uuid2); originalList.add(uuid3); List<String> expectedList = new ArrayList<>(); String expectedUuidStr1 = Values.convertToString(CassandraTypeKafkaSchemaBuilders.UUID_TYPE, UuidUtil.asBytes(uuid1)); String expectedUuidStr2 = Values.convertToString(CassandraTypeKafkaSchemaBuilders.UUID_TYPE, UuidUtil.asBytes(uuid2)); String expectedUuidStr3 = Values.convertToString(CassandraTypeKafkaSchemaBuilders.UUID_TYPE, UuidUtil.asBytes(uuid3)); expectedList.add(expectedUuidStr1); expectedList.add(expectedUuidStr2); expectedList.add(expectedUuidStr3); ListType<UUID> frozenListType = ListType.getInstance(UUIDType.instance, false); ByteBuffer serializedList = frozenListType.decompose(originalList); Object deserializedList = CassandraTypeDeserializer.deserialize(frozenListType, serializedList); Assert.assertEquals(expectedList, deserializedList); }
public static Object deserialize(DataType dataType, ByteBuffer bb) { AbstractType abstractType = CassandraTypeConverter.convert(dataType); return deserialize(abstractType, bb); }
CassandraTypeDeserializer { public static Object deserialize(DataType dataType, ByteBuffer bb) { AbstractType abstractType = CassandraTypeConverter.convert(dataType); return deserialize(abstractType, bb); } }
CassandraTypeDeserializer { public static Object deserialize(DataType dataType, ByteBuffer bb) { AbstractType abstractType = CassandraTypeConverter.convert(dataType); return deserialize(abstractType, bb); } private  CassandraTypeDeserializer(); }
CassandraTypeDeserializer { public static Object deserialize(DataType dataType, ByteBuffer bb) { AbstractType abstractType = CassandraTypeConverter.convert(dataType); return deserialize(abstractType, bb); } private  CassandraTypeDeserializer(); static Object deserialize(DataType dataType, ByteBuffer bb); static Object deserialize(AbstractType<?> abstractType, ByteBuffer bb); static Object deserialize(CollectionType<?> collectionType, ComplexColumnData ccd); static SchemaBuilder getSchemaBuilder(AbstractType<?> abstractType); static TypeDeserializer getTypeDeserializer(AbstractType<?> abstractType); }
CassandraTypeDeserializer { public static Object deserialize(DataType dataType, ByteBuffer bb) { AbstractType abstractType = CassandraTypeConverter.convert(dataType); return deserialize(abstractType, bb); } private  CassandraTypeDeserializer(); static Object deserialize(DataType dataType, ByteBuffer bb); static Object deserialize(AbstractType<?> abstractType, ByteBuffer bb); static Object deserialize(CollectionType<?> collectionType, ComplexColumnData ccd); static SchemaBuilder getSchemaBuilder(AbstractType<?> abstractType); static TypeDeserializer getTypeDeserializer(AbstractType<?> abstractType);  }