请稍等 ...
×

采纳答案成功!

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

正在回答

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下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号