禁用PySpark sql中的某些函数

from pyspark.sql.functions import udf

def custom_substring(s, start, length):
    return s[start:start+length]

substring_udf = udf(custom_substring)

# 使用自定义函数替代substring函数
df = df.withColumn("new_column", substring_udf(df["column"], lit(1), lit(5)))

from pyspark.sql.functions import expr

# 使用expr函数替代substring函数
df = df.withColumn("new_column", expr("substring(column, 1, 5)"))

# 使用selectExpr方法替代substring函数
df = df.selectExpr("column", "substring(column, 1, 5) as new_column")