pyspark 函数更改数据类型

Question

代码在函数外部工作，但是当我将其放入函数内部并调整传递的 var 参数时，我收到错误消息。感谢您的帮助！

from pyspark.sql.types import DateType
from pyspark.sql.functions import col, unix_timestamp, to_date

def change_string_to_date(df,var):       
     df = df.withColumn("{}".format(var),to_date(unix_timestamp(col("{}".format(var))), 'yyyy-MM-dd').cast("timestamp"))    
     return df

df_data = change_string_to_date(df_data,'mis_dt')

Answer 1

想通了。 “unix_timestamp”导致了问题。非常愚蠢的错误。