使用spark读取elasticsearch中的数据，使用es提供的api来进行，
sc.esRDD("logstash").valuessc.
阅读背景：
spark 读取elasticsearch中数据不完整问题
来源：互联网
分享到：
