小编Par*_*jit的帖子

我有一个数据帧,我想使用该数据帧的replace()函数之一 org.apache.spark.sql.DataFrameNaFunctions.

问题:我没有使用dataframe的实例获得智能(建议)中的这些方法.我明确地导入了这个类.

我无法找到任何可以给我演示如何使用这些函数或如何将数据帧转换为类型的东西DataFrameNaFunctions.

我尝试使用asInstanceof[]方法强制转换它但它抛出异常.

我试图从RDD创建一个Dataframe [cassandraRow] ..但我不能因为createDataframe(RDD [Row],schema:StructType)需要RDD [Row]而不是RDD [cassandraRow].

• 我怎样才能做到这一点？

并且根据这个问题的答案 如何将rdd对象转换为spark中的dataframe

(其中一个答案)建议在RDD [Row]上使用toDF()从RDD获取Dataframe,这对我不起作用.我尝试在另一个例子中使用RDD [Row](尝试使用toDF()).

• 对于我来说,我们怎么能用RDD(RDD [Row])的实例调用Dataframe(toDF())的方法呢？

我正在使用Scala.