Spark 读写 Es_spark 修改 es 别名 alias-CSDN博客

网站介绍:文章浏览阅读1.6k次,点赞3次,收藏4次。前言有个新需求说来比较简单,就是spark读取hive中的数据,处理完后入es,这里就是简单整理一下流程流程伪代码object Credit_User_Model_To_Es { def main(args: Array[String]): Unit = { val spark = SparkSession .builder() .appName(nam..._spark 修改 es 别名 alias