Spark/ScalaでNULL値をゼロに代入する方法

Question

いくつかの列がString型で、NULLをString値（実際のNULLではない）として含むDataframeがあります。私はそれらをゼロで転用したい。明らかにdf.na.fill(0)は機能しません。どのように私はそれらを0で置き換えることができますか？あなたはまた、この動作を複製し、独自のudfを作成することができ

val df1 = df.na.replace("*", Map("NULL" -> "0")) 

：あなたはこれらの接頭辞.naによってアクセスすることができ、DataFrameNaFunctionsからreplace()を使用することができます

Answer 1

import org.apache.spark.sql.functions.col 

val nullReplacer = udf((x: String) => { 
    if (x == "NULL") "0" 
    else x 
}) 

val df1 = df.select(df.columns.map(c => nullReplacer(col(c)).alias(c)): _*) 

しかしこれは次のようになります必要以上に多くのコード行を犠牲にして、上記と同じことを行うと余分なものがあります。