您的位置:首页 > 数据库 > Mongodb

mongoDb的mapReduce应用 外部变量使用关键部分springMVC;

2020-03-05 09:42 731 查看

long interval = 900000;
long startTime = new Date("2016/03/01 01:00:00").getTime();
long endTime = new Date("2016/03/31 23:59:59").getTime();
String tagUid=(String) arr.get(i);

Query query = Query.query(Criteria.where("TagGuid").in(tagUid));//查询过滤条件
query.addCriteria(Criteria.where("mDay").is(1));//添加过滤条件
MapReduceOptions options = MapReduceOptions.options();//设置reduce配置项
Map scope = new HashMap();
scope.put("interval", interval);
scope.put("startTime", startTime);
options.scopeVariables(scope).verbose(true).outputTypeInline();//mapreduce外部变量插入
String mapFunction1 = "function () {"
+ "var sSecond=new Date(this.Atime).getTime(),"
+ "tag=parseInt((sSecond-startTime)/interval);"
+ "emit({guid:this.TagGuid,time:tag},{tagUid:this.TagGuid,atime:this.Atime,value:this.TagValue,year:this.mYear,month:this.mMonth,day:this.mDay,seeId:this.SeeID})}";//map方法编写
String reduceFunction = "function(key,values){ return values[0];} ";//reduce方法编写
MapReduceResults<ReturnMessage> result = mongoTemplate.mapReduce(query, "Hdata03", mapFunction1, reduceFunction,options, ReturnMessage.class);//方法调用
Iterator<ReturnMessage> it = result.iterator();//得到结果
long p=0;
while (it.hasNext()) {
ReturnMessage message = it.next();//自定义实体类容器
String  key=(String) JSONObject.fromObject(message.getId()).get("guid");
String insertSql="INSERT  INTO  t_base_data (data) VALUES  ('"+message.getValue()+"')";//插入postgresql
baseDao.updateBySql(insertSql);
}

最后插入postgesql做了循环插入  很不科学,浪费大量时间;

主要演示了一个mapreduce全局变量的使用;

其他循环只是测试用的,有点累赘;可以不看;

转载于:https://www.cnblogs.com/xiaomurunning/p/7448569.html

  • 点赞
  • 收藏
  • 分享
  • 文章举报
anchentan3472 发布了0 篇原创文章 · 获赞 0 · 访问量 26 私信 关注
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐