身安不如心安,屋宽不如心宽 。

spark读取Elasticsearch数据不完整问题

Elasticsearch | 作者 mazedfishs | 发布于2017年09月22日 | 阅读数:2612

val esRdd = sc.esRDD("index/type")
esRdd.foreach( line => println(line._1+"\n"+line._2) )
返回结果line._2 Map<String, Object> 只有部分字段
已邀请:

mazedfishs

赞同来自:

貌似是因为字段值为null导致,这种应该怎么解决呢

mazedfishs

赞同来自:

换成esJsonRDD就好了
 

要回复问题请先登录注册