磚

由於我按你的建議修改我的代碼,它完美的再次感謝你所有的工作inputsdflist = spark.createDataFrame(列表(a.columns),“字符串”).toDF(“名字”)脫硫= dflist.filter(坳(“名字”).isin (ref_date)) .count()如果dfg = = 1: a = a.wi……

是的,你的理解是正確的,我需要一個列可能會動態地創建或既存的dataframe如果列存在的函數應該返回列作為輸出如果新創建應該retu……

AttributeError: DataFrame對象沒有屬性的ColumnChecker 'def func_udf (df,坳):列=列表(df.columns)如果坳列:df返回。上校:df。withColumn(“上校”,點燃(null)) spark.udf.register (“ColumnChecker”, func_udf)脫硫= a.ColumnC……

請查收附加的文件

從pyspark.sql。函數從pyspark.sql進口*。功能導入colimport pyspark.sql。函數作為Ffrom datetime進口日期,從dateutil datetimeimport時間。relativedelta進口relativedeltafrom dateutil進口parserfrom pyspark.sql.window……