val rdd=sc.parallelize(List(("Jack","America","23"),("Mark","China","25"),("Lura","Australia","24")))
import sqlContext.implicits._
val df=rdd.repartition(1).toDF("name","country","age")//写文件的个数为repartition数
df.write.option("header",true).option("encoding", "UTF-8").csv("C:\\Users\\peanut\\Desktop\\myStudent")
scala 写csv文件
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。