@classmethod
    def setUpClass(cls):
        super(UDTTest, cls).setUpClass()

        cls.udt_support = 4 >= cls.session.cluster.protocol_version
        if cls.udt_support:
            for name, udt in cls.types.items():
                cls.session.execute('''
                    CREATE TYPE IF NOT EXISTS %s (
                        %s
                    )
                ''' % (name, ',\n\t'.join('%s %s' % f for f in udt.items())))

            fields = ', '.join(
                '{udt_type} frozen<{udt_type}>'.format(udt_type=udt_type)
                for udt_type in cls.types
            )

            fields += ', ' + ', '.join(
                '{udt_type}_{col_type} {col_type}<frozen<{udt_type}>>'.format(udt_type=udt_type, col_type=col_type)
                for udt_type in cls.types
                for col_type in ('set', 'list')
            )

            cls.session.execute('''
                CREATE TABLE IF NOT EXISTS %s (
                    key text primary key, %s
                )
            ''' % (cls.table, fields))
dataset/ETHPy150Open TargetHolding/pyspark-cassandra/python/pyspark_cassandra/tests.py/UDTTest.setUpClass/swapped operands of `>=`