典雅樱桃

文章
4
资源
0
加入时间
2年10月17天

Spark读写ES

1.创建spark对象并配置读取es的连接信息//创建spark上下文对象 val spark = SparkSession .builder() .appName("test") .config("spark.port.maxretries", "128") .config("spark.sql.parquet.writelegacyFormat", true)