mongodb - 带有 $date 的 mongo.input.query 不过滤输入到 hadoop

Question

我有一个分片输入集合，我想在将其发送到我的 hadoop 集群以进行 map reduce 计算之前对其进行过滤。

我的 $ hadoop jar - 命令中有这个参数

mongo.input.query='{_id.uuid:"device-964693"}'

并且有效。输出不会 mapreduce 任何不满足此查询的数据。

但这不起作用:

mongo.input.query='{_id.day:{\\$lt:{\\$date:1388620740000}}}'

没有数据作为输出产生。

1388620740000 表示日期 Wed Jan 01 2014 23:59:00 GMT+0000 (GMT)。该设置使用的是 hadoop 2.2、mongo 2.4.9，this连接器版本 (2.2-1.2.0)。

没有错误消息，只有标准的 hadoop 成功消息。

是我的语法不正确还是遗漏了什么？

你能为我指出一些调试工具/方法吗？

Answer 1

调试方法:

在蒙戈中:

db.currentOp(true).inprog.forEach(
   function(d){
     if(d.ns == "test.collection" && d.query.query["_id.day"] )
        printjson(d);
     })

终端友好的语法:

$ hadoop jar... ...mongo.input.query='{"_id.day":{"$lt":{"$date":"2014-01-19T23:00:00Z"}}}'