dataFrame保存,write算子,
亲测
write算子,保存不同的格式
people.withColumnRenamed("job number","jobId")
.write.format("json")
.mode("append")
.save("/tmp/test/data/pjson100")
people.withColumnRenamed("job number","jobId").write.saveAsTable("ptable")
spark.sql("select * from ptable").show
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。