def test_collection_of_udts(self):
        super(UDTTest, self).read_write_test('simple_udt_list', None)

        udts = [UDT(col_text='text ' + str(i), col_int=i, col_boolean=bool(i % 2)) for i in range(10)]
        super(UDTTest, self).read_write_test('simple_udt_set', set(udts))
        super(UDTTest, self).read_write_test('simple_udt_list', udts)

        udts = [UDT(col_text='text ' + str(i), col_int=i, col_boolean=None) for i in range(10)]
        super(UDTTest, self).read_write_test('simple_udt_set', set(udts))
        super(UDTTest, self).read_write_test('simple_udt_list', udts)
dataset/ETHPy150Open TargetHolding/pyspark-cassandra/python/pyspark_cassandra/tests.py/UDTTest.test_collection_of_udts/original