您可以使用
.na.fillfunction(它是org.apache.spark.sql.DataframeNaFunctions中的函数)。
基本上,您需要的功能是:
def fill(value: String, cols: Seq[String]): Dataframe
您可以选择列,然后选择要替换null或NaN的值。
在您的情况下,它将类似于:
val df2 = df.na.fill("a", Seq("Name")) .na.fill("a2", Seq("Place"))
您可以使用
.na.fillfunction(它是org.apache.spark.sql.DataframeNaFunctions中的函数)。
基本上,您需要的功能是:
def fill(value: String, cols: Seq[String]): Dataframe
您可以选择列,然后选择要替换null或NaN的值。
在您的情况下,它将类似于:
val df2 = df.na.fill("a", Seq("Name")) .na.fill("a2", Seq("Place"))