使用spark与ElasticSearch交互

使用 elasticsearch-hadoop 包，可在 github 中搜索到该项目node 项目地址git example import org.elasticsearch.spark._ import org.elasticsearch.spark.sql._ val conf = new SparkConf() .set("es.nodes","192.168.47.155")

>>阅读原文<<