4

MapReduce の reduce 関数が正しく機能していないようです。これが私のマップ関数です:

function Map() {
    day = Date.UTC(this.TimeStamp.getFullYear(), this.TimeStamp.getMonth(),this.TimeStamp.getDate());   

    emit(
        {
            search_dt: new Date(day),
            user_id: this.UserId
        },                  
        {
            timestamp: this.TimeStamp
        }   
    ); 

}

そして、ここに私のreduce関数があります:

function Reduce(key, values) {

    var result = [timestamp:0];

    values.forEach(function(value){
        if (!value.timestamp)
            continue;
        if (result.timestamp < value.timestamp)
            result.timestamp = value.timestamp; 
    }); 
    return result;

}

グループ化されたオブジェクトの最新の日付を取得したい。私は何を間違っていますか?

4

1 に答える 1

0

次のアプローチのいずれかを使用することを検討しましたか?

コレクションでMAX timeStampFieldを見つけます。

db.collectionName.ensureIndex( { "timeStampField": -1 } );
db.collectionName.find({},{"timeStampField":1}).sort({timeStampField:-1}).limit(1);

また:

コレクション内のuser_idごとに MAX timeStampFieldを見つけます(DB がシャーディングされていない場合):

db.collectionName.group(
  {  key: { "user_id" : 1 }
   , initial: { maxTimeStamp   : new Timestamp()  }
   , cond:    { timeStampField : {$exists : true}, timeStampField : {$gt: new Timestamp()} }
   , reduce:  function(doc,out) { 
                  if (out.maxTimeStamp < doc.timeStampField) { 
                      out.maxTimeStamp = doc.timeStampField; 
                  }
              }
  }
);
于 2012-11-17T06:58:58.027 に答える