Spark Scala數據幀等級分類

-4

你好，我有原始數據，比如1我想添加一個以80爲中斷點的列作爲合格等級，結果應該是2。我正在使用sqlContext.read.format（「com.databricks.spark.csv」）來讀取原始數據。任何幫助！Spark Scala數據幀等級分類

來源

2017-10-28 Foaad Mohamad Haddod

我一直在使用.withColumn（「列名」試過，但我解決不了的問題 –

使用.withColumn()將如預期：

val resultUDF = udf((total: Int) => if(total >= 80) "pass" else "fail") 
df.withColumn("result", resultUDF($"total"))

來源

2017-10-29 06:42:17 vdep

感謝ü但我得到這個錯誤：任何建議 –

發佈完整的'堆棧跟蹤' – vdep

這就是我想要做的：val resultUDF = udf（（「Bin％」：Int）=> if（「Bin％」> =「80」）「pass」else「fail 「） dTestSample1.withColumn（」result「，resultUDF（$」Bin％「））。show（）並且不能運行它bcz的： –

Spark Scala數據幀等級分類

回答

相關問題