保存成HDFS是必须是RDD[String] 类型
比如一个 val s = "12e2321312"
spark.sparkContext.parallelize(s)
直接这样返回的是 RDD[Char] 类型
spark.sparkContext.parallelize(Seq(s))
这样返回的就是RDD[String]
![spark RDD[Char] to 转换 RDD[String]](http://www.mshxw.com/aiimages/31/720811.png "spark RDD[Char] to 转换 RDD[String]")
保存成HDFS是必须是RDD[String] 类型
比如一个 val s = "12e2321312"
spark.sparkContext.parallelize(s)
直接这样返回的是 RDD[Char] 类型
spark.sparkContext.parallelize(Seq(s))
这样返回的就是RDD[String]
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
