第1关:SparkSQL加载和保存
在右侧编辑器补充代码,加载people.json
文件,以覆盖的方式保存到people
路径里,继续加载people1.json
文件,以附加的方式保存到people
路径里,最后以表格形式显示people
里前20
行Dataset
。文章来源地址https://www.toymoban.com/news/detail-444892.html
package com.educoder.bigData.sparksql2;
import org.apache.spark.sql.AnalysisException;
import org.apache.spark.sql.SaveMode;
import org.apache.spark.sql.SparkSession;
public class Test1 {
public static void main(String[] args) throws AnalysisException {
SparkSession spark = SparkSession
.builder()
.appName("test1")
.master("local")
.getOrCreate();
/********* Begin *********/
spark.read().format("json").load("people.json").write().mode(SaveMode.Append).save("people");
spark.read().format("json").load("people1.json").write().mode(SaveMode.Append).save("peopl
文章来源:https://www.toymoban.com/news/detail-444892.html
到了这里,关于Spark数据源educoder的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!