使用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")

>>阅读原文<<