请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

正在回答

1回答

借助于外部数据源spark-csv就行了,只要format(“csv”)就行了

0 回复 有任何疑惑可以回复我~
  • 报了这个错
    Exception in thread "main" java.lang.RuntimeException: Multiple sources found for csv (org.apache.spark.sql.execution.datasources.csv.CSVFileFormat, com.databricks.spark.csv.DefaultSource15), please specify the fully qualified class name.
    
    
    我的代码是
     accessDF.join(accessDF2,accessDF.col("spu_id")===accessDF2.col("spu_id2"))
             .select("spu_id","brand_id","cat_id","uid","action_type","date")
          .coalesce(5).write.mode(SaveMode.Overwrite).csv("F:\\竞赛数据\\result\\goods_train")
    回复 有任何疑惑可以回复我~ 2017-07-21 14:00:13
  • 非常感谢!
    回复 有任何疑惑可以回复我~ 2017-07-22 18:44:26
问题已解决,确定采纳
还有疑问,暂不采纳
意见反馈 帮助中心 APP下载
官方微信