def square(x):

    return x * x



square_udf = udf(square, IntegerType())

df = df.withColumn('sales_squared', square_udf(df.sales))

def square(x):

    return x * x



df = df.withColumn('sales_squared', square(df.sales))

def square(x):

    return x * x



df = df.withColumn('sales_squared', udf(square, IntegerType())('sales'))

def square(x):

    return x * x



square_udf = udf(square, IntegerType)

df = df.withColumn('sales_squared', square_udf('sales'))

def square(x):

    return x ** 2



square_udf = udf(square, IntegerType())

df = df.withColumn('sales_squared', square_udf('sales'))