सभी PySpark UDFs को udf() फंक्शन से रजिस्टर करना होता है.

# Define the function
def to_uppercase(s):
    return s.upper() if s else None


# Register the function
to_uppercase_udf = udf(to_uppercase, StringType())


# Apply the UDF to the DataFrame
df = df.withColumn("name_upper", to_uppercase_udf(df["name"]))


# See the results
df.show()

याद रखें: UDFs आपको PySpark DataFrames पर कस्टम Python लॉजिक लगाने देते हैं