好吧,我正在尝试将此sql查询转换为映射减少
select
o_orderpriority,
count(*) as order_count
from
orders
where
o_orderdate >= date '1993-07-01'
and o_orderdate < date '1993-07-01' + interval '3' month
and exists (
select
*
from
lineitem
where
l_orderkey = o_orderkey
and l_commitdate < l_receiptdate
)
group by
o_orderpriority
order by
o_orderpriority;
我尝试了以下地图缩减功能
db.runCommand({
mapreduce: "orders",
query: {
o_orderdate: {'$gte': new Date("July 01, 1993")},
o_orderdate: {'$lt': new Date("Oct 01, 1993")}
},
map: function Map() {
for(var i in this.o_lineitem) {
if( this.o_lineitem[i].l_commitdate < this.o_lineitem[i].l_receiptdate) {
var o_orderpriority = this.o_lineitem[i].o_orderpriority;
emit( o_orderpriority, {count: 1} );
}
}
},
reduce: function(key, values) {
var count= 0;
for (var i = 0; i < values.length; i++) {
count+= values[i];
}
return count;
},
out: 'query004'
});
当 I 运行时,我收到以下警报
8 月 11 日星期六 20:44:32 语法错误:缺少 ) 条件后(外壳):9
对我来说,没有)缺失,是吗?
我做了@Stenie指出的更正,但现在我有以下问题
{
"assertion" : "value too large to reduce",
"assertionCode" : 13070,
"errmsg" : "db assertion failure",
"ok" : 0
}
问题是你的 emit 和 reduce 函数不返回相同的东西。
映射函数发出以下值:
{count: 1}
这意味着您的reduce必须返回相同的格式。
你在reduce中返回一个简单的值:
return count;
您可以将 emit 更改为仅发出 1 而不是 JSON 文档,然后您不必更改 reduce,否则更改 reduce 以返回 JSON 文档 {count: X},其中 X 是计算的计数。
仅供参考,这导致错误"值太大而无法减少"的原因是,一旦您像这样混合类型,"+"运算符就会开始连接您的值而不是添加它们,最终它变得太大。 要了解如何调试它,我推荐MapReduce故障排除页面。