连续文档之间的mapreduce

Question

设置：

我得到了一个包含以下条目的大型集合

Name - String 
Begin - time stamp
End - time stamp

问题：

我想获取文档之间的差距，使用 map-reduce 范例。

方法：

我正在尝试设置一个新的对集合 mid，之后我可以使用 $unwind 和 Pair[1].Begin - Pair[0].End 计算与其之间的差异

function map(){
    emit(0, this)
}
function reduce(){
    var i = 0;
    var pairs = [];
    while ( i < values.length -1){
        pairs.push([values[i], values[i+1]]);
        i = i + 1;
    }
    return {"pairs":pairs};
}
db.collection.mapReduce(map, reduce, sort:{begin:1}, out:{replace:"mid"})

这适用于有限数量的文档，因为文档上限为 16MB。我不确定是否需要将集合放入内存并在那里执行，我还能如何解决这个问题？

Answer 1

MongoDB 的 mapReduce 函数处理您提出的问题的方法与您用于解决问题的方法不同。这里的关键因素是“保留”“上一个”文档以便与下一个文档进行比较。

支持这一点的实际机制是“范围”功能，它允许在整个代码中使用一种“全局”变量方法。正如您将看到的，您在考虑什么时候提出的问题根本不需要“减少”，因为没有“分组”，只是发出文档“对”数据：

db.collection.mapReduce(
    function() {
        if ( last == null ) {
           last = this;
        } else {
            emit( 
                {
                    "start_id": last._id,
                    "end_id": this._id
                },
                this.Begin - last.End
            );
            last = this;
        }
    },
    function() {}, // no reduction required
    {
        "out": { "inline": 1 },
        "scope": { "last": null }
    }
)

根据您的尺寸要求输出一个集合作为输出。

但是这种方式通过使用“全局”来保留最后一个文档，那么代码既简单又高效。