浏览代码

mapReduce时合并而不是替换数据

airhead 8 年之前
父节点
当前提交
d01d0ca0ca
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      hos-camel2/src/main/java/camel/monitor/processor/ServiceMonitorService.java

+ 1 - 1
hos-camel2/src/main/java/camel/monitor/processor/ServiceMonitorService.java

@ -84,7 +84,7 @@ public class ServiceMonitorService {
        document = document.append("reduce", reduceFunc);
        String query = "{fireTime:{$gte:new Date(\"" + beginTime + "\"), $lt:new Date(\"" + endTime + "\")}}";
        document = document.append("query", Document.parse(query));
        document = document.append("out", SERVICE);
        document = document.append("out", new Document("merge", SERVICE));
        database.runCommand(document);
    }