将 Elasticsearch DSL 查询与 Hadoop Mapreduce 结合使用

【问题标题】：Using Elasticsearch DSL Query with Hadoop Mapreduce将 Elasticsearch DSL 查询与 Hadoop Mapreduce 结合使用
【发布时间】：2014-08-06 07:09:17
【问题描述】：

我正在尝试从 mapreduce 连接到 Elasticsearch。我使用了一个很棒的tutorial。要查询 elasticsearch，它使用 uri search 工作正常：

Configuration conf = new Configuration();
conf.set("es.resource", "radio/artists/");            
conf.set("es.query", "?q=me*");

我很好奇是否可以以某种方式使用query dsl。我什么也没找到。

谢谢

【问题讨论】：

标签： java hadoop mapreduce elasticsearch querydsl

【解决方案1】：

好的，可以使用 Query DSL，而且非常简单。您需要做的就是将查询编辑为以{ 开头并以} 结尾。所以它看起来像：

conf.set("es.query", { "query" : { "term" : { "user" : "costinl" } } });

或者可以使用外部json文件：

conf.set("es.query", "some.json");

更多信息请联系here。

【讨论】：