List String的RDD转换为Row
RDD of List String convert to Row
我正在尝试将具有固定大小的字符串列表(解析 CSV 文件的结果)的 RDD 转换为行的 RDD。这样我就可以把它变成一个数据框,因为我需要把它变成一个数据框来写入镶木地板。无论如何,我唯一需要帮助的部分是将 Rdd 从字符串列表转换为 Row。
RDD变量名是RDD
我用过:
import org.apache.spark.sql._
val RowRDD = RDD.map(r => Row.fromSeq(r))
我正在尝试将具有固定大小的字符串列表(解析 CSV 文件的结果)的 RDD 转换为行的 RDD。这样我就可以把它变成一个数据框,因为我需要把它变成一个数据框来写入镶木地板。无论如何,我唯一需要帮助的部分是将 Rdd 从字符串列表转换为 Row。
RDD变量名是RDD
我用过:
import org.apache.spark.sql._
val RowRDD = RDD.map(r => Row.fromSeq(r))