瀏覽
磚
幫助
登錄
開始使用磚
開始討論
開始資源
磚平台Beplay体育安卓版本
技術博客
磚平台的討論Beplay体育安卓版本
工程數據
機器學習
倉庫&分析
數據治理
管理和架構
學習
學習討論
培訓產品
認證
學習路徑
認證
組
地區和利益集團
美洲
亞太地區
利益集團
事件
社區灣
社區討論
社區新聞&成員認可
cuteabhi32
新的貢獻者三世
自
06-06-2022
06-26-2023
用戶數據
7
的帖子
0
解決方案
1
榮譽給
0
榮譽收到
磚
關於cuteabhi32
用戶活動
的帖子
回複
試圖檢查是否一個列中存在dataframe如果不是,那麼我必須給零如果是的,那麼我需要給列本身使用UDF
06-06-2022
從pyspark進口SparkContextfrom pyspark進口SparkConffrom pyspark.sql。從pyspark.sql進口*類型。函數從pyspark進口*。sql從pyspark.sql進口*。類型進口StringTypefrom pyspark.sql。功能導入udfdf1 = spark.read.form……
Re:試圖檢查是否一個列中存在dataframe如果不是,那麼我必須給零如果是的,那麼我需要給列本身使用UDF
06-07-2022
由於我按你的建議修改我的代碼,它完美的再次感謝你所有的工作inputsdflist = spark.createDataFrame(列表(a.columns),“字符串”).toDF(“名字”)脫硫= dflist.filter(坳(“名字”).isin (ref_date)) .count()如果dfg = = 1: a = a.wi……
Re:試圖檢查是否一個列中存在dataframe如果不是,那麼我必須給零如果是的,那麼我需要給列本身使用UDF
06-07-2022
是的,你的理解是正確的,我需要一個列可能會動態地創建或既存的dataframe如果列存在的函數應該返回列作為輸出如果新創建應該retu……
Re:試圖檢查是否一個列中存在dataframe如果不是,那麼我必須給零如果是的,那麼我需要給列本身使用UDF
06-07-2022
AttributeError: DataFrame對象沒有屬性的ColumnChecker 'def func_udf (df,坳):列=列表(df.columns)如果坳列:df返回。上校:df。withColumn(“上校”,點燃(null)) spark.udf.register (“ColumnChecker”, func_udf)脫硫= a.ColumnC……
Re:試圖檢查是否一個列中存在dataframe如果不是,那麼我必須給零如果是的,那麼我需要給列本身使用UDF
06-07-2022
請查收附加的文件
Re:試圖檢查是否一個列中存在dataframe如果不是,那麼我必須給零如果是的,那麼我需要給列本身使用UDF
06-07-2022
從pyspark.sql。函數從pyspark.sql進口*。功能導入colimport pyspark.sql。函數作為Ffrom datetime進口日期,從dateutil datetimeimport時間。relativedelta進口relativedeltafrom dateutil進口parserfrom pyspark.sql.window……
查看更多
榮譽給
用戶
數
werners1
1
查看所有
map