新利18luck打不开

微信号:BestWebDesign长按上图,弹出“识别二维码”后关注UI设计达人「UI设计达人」分享UI设计精选文章、案例、行业趋势、课程和书籍。注:图片来自http://www.michael-noll.com/blog/2013/01/18/implementing-real-time-trending-topics-in-storm/TopologyStringspoutId="wordGenerator";StringcounterId="counter";StringintermediateRankerId="intermediateRanker";StringtotalRankerId="finalRanker";//这里,假设TestWordSpout就是我们发送话题tuple的源builder.setSpout(spoutId,newTestWordSpout(),5);//RollingCountBolt的时间窗口为9秒钟,每3秒发送一次统计结果到下游builder.setBolt(counterId,newRollingCountBolt(9,3),4).fieldsGrouping(spoutId,newFields("word"));//IntermediateRankingsBolt,将完成部分聚合,统计出top-n的话题builder.setBolt(intermediateRankerId,newIntermediateRankingsBolt(TOP_N),4).fieldsGrouping(counterId,newFields(??"obj"));??//TotalRankingsBolt,将完成完整聚合,统计出top-n的话题builder.setBolt(totalRankerId,newTotalRankingsBolt(TOP_N)).globalGrouping(intermediateRankerId);上面的topology设计如下:注:图片来自http://www.michael-noll.com/blog/2013/01/18/implementing-real-time-trending-topics-in-storm/将聚合计算与时间结合起来前文,我们叙述了tick事件,回调中会触发bolt的execute方法,那可以这么做:RollingCountBolt:@Overridepublicvoidexecute(Tupletuple){?if(TupleUtils.isTick(tuple)){??LOG.debug("Receivedticktuple,triggeringemitofcurrentwindowcounts");??//tick来了,将时间窗口内的统计结果发送,并让窗口滚动??emitCurrentWindowCounts();?}?else{??//常规tuple,对话题计数即可??countObjAndAck(tuple);?}}?//obj即为话题,增加一个计数count++//注意,这里的速度基本取决于流的速度,可能每秒百万,也可能每秒几十.//内存不足?bolt可以scale-out.privatevoidcountObjAndAck(Tupletuple){?Objectobj=tuple.getValue(0);?counter.incrementCount(obj);?collector.ack(tuple);}?//将统计结果发送到下游privatevoidemitCurrentWindowCounts(){?Mapcounts=counter.getCountsThenAdvanceWindow();?intactualWindowLengthInSeconds=lastModifiedTracker.secondsSinceOldestModification();?lastModifiedTracker.markAsModified();?if(actualWindowLengthInSeconds!=windowLengthInSeconds){??LOG.warn(String.format(WINDOW_LENGTH_WARNING_TEMPLATE,actualWindowLengthInSeconds,windowLengthInSeconds));?}?emit(counts,actualWindowLengthInSeconds);}上面的代码可能有点抽象,看下这个图就明白了,tick一到,窗口就滚动:注:图片来自http://www.michael-noll.com/blog/2013/01/18/implementing-real-time-trending-topics-in-storm/IntermediateRankingsBolt&TotalRankingsBolt:publicfinalvoidexecute(Tupletuple,BasicOutputCollectorcollector){?if(TupleUtils.isTick(tuple)){??getLogger().debug("Receivedticktuple,triggeringemitofcurrentrankings");??//将聚合并排序的结果发送到下游??emitRankings(collector);?}?else{??//聚合并排序??updateRankingsWithTuple(tuple);?}}其中,IntermediateRankingsBolt和TotalRankingsBolt的聚合排序方法略有不同:IntermediateRankingsBolt的聚合排序方法://IntermediateRankingsBolt的聚合排序方法:?@Override?voidupdateRankingsWithTuple(Tupletuple){??//这一步,将话题、话题出现的次数提取出来??Rankablerankable=RankableObjectWithFields.from(tuple);??//这一步,将话题出现的次数进行聚合,然后重排序所有话题??super.getRankings().updateWith(rankable);?}TotalRankingsBolt的聚合排序方法://TotalRankingsBolt的聚合排序方法?@Override?voidupdateRankingsWithTuple(Tupletuple){?//提出来自IntermediateRankingsBolt的中间结果??RankingsrankingsToBeMerged=(Rankings)tuple.getValue(0);?//聚合并排序??super.getRankings().updateWith(rankingsToBeMerged);?//去0,节约内存??super.getRankings().pruneZeroCounts();?}而重排序方法比较简单粗暴,因为只求前N个,N不会很大:privatevoidrerank(){?Collections.sort(rankedItems);?Collections.reverse(rankedItems);}结语下图可能就是我们想要的结果,我们完成了t0?t1时刻之间的热点话题统计,其中的foreach_break仅仅是为了防盗版:].文中对滑动窗口计数的概念和关键代码做了较为详细解释,如果还有不理解,请参考http://www.michael-noll.com/blog/2013/01/18/implementing-real-time-trending-topics-in-storm/的设计以及storm的源码.觉得本文对你有帮助?请分享给更多人关注「ImportNew」,看技术干货SpringProfile和Mybatis进行多个数据源的切换{###}(点击上方公众号,可快速关注)来源:黄亿华,my.oschina.net/flashsword/blog/209872如有好文章投稿,请点击→这里了解详情最近在做WebMagic的后台,遇到一个问题:后台用到了数据库,本来理想情况下是用Mysql,但是为了做到开箱即用,也整合了一个嵌入式数据库H2。重新标记:用于修正并发标记期间由于用户程序继续运行而导致标记产生变动的那部分记录,这个过程会暂停所有线程,但其停顿时间远比并发标记的时间短;并发清理:可以和用户线程一起工作。
中国教育在线 中国教育网 加入收藏 设为首页

MBA报考流程

http://mba.eol.cn  网络    2017-05-10    

  MBA报考流程

  1、网上报名阶段(10月10日-31日):

  考生自行登录中国在职研究生招生信息网(http://yz.chsi.com.cn/)先进行注册,然后登陆,请记住自己的用户名和密码;网上报名又详细分为9个小步骤

  a、阅读教育部公告

  选择“同意”,即可进入下一步。

  b、阅读考试承诺书

  选择“同意”,即可进入下一步。

  c、选择报考单位

  报考单位为考生所要报考院校,以报考北京大学为例,报考单位应选择“北京大学”,MBA考生考试方式仅能选择“管理类联考”。

  d、填写个人信息1

  e、填写个人信息2

  f、选择报考专业

  g、选择报考点

  h、校对填报信息

  仔细校对填报信息,确定准确无误后,确认即可。

  i、完成报名

  确认提交报名信息后,系统会生成报名号表明报名成功。中国在职研究生招生信息网再次提醒广大考生,一定要牢记登陆中国研究生招生信息网的用户名、密码及报名号,后期现场确认、准考证下载和调剂系统仍需要使用。

  2、现场确认阶段(11月中旬):

  a、现场确定的地点就是所报考的院校,或有报考院校指定的确认地点。

  b、现场确认需携带的资料:本人第二代居民身份证;学历证书(普通高校、成人高校、普通高校举办的成人高校学历教育应届本科毕业生持学生证);网上报名编号(即网上报名成功后系统显示的9位数字报名号);其它招生单位或报考点规定的相关材料。

  c、所需确认程序:考生将本人第二代居民身份证、学历证书(普通高校、成人高校、普通高校举办的成人高校学历教育应届本科毕业生持学生证)和网上报名编号,由报考点工作人员进行核对;考生本人对网上报名信息要进行认真核对并确认。经考生确认的报名信息在考试、复试及录取阶段一律不作修改,因考生填写错误引起的一切后果由其自行承担;考生按规定缴纳报考费。(考生办理报考手续缴纳报考费后,不再退还);采集考生图像信息。

  现场确认是学员成功考研的前提,考生应提高警惕,必须在规定的现场确认时间、地点内,带好全部的证件报到,切勿在报考流程中出差错,造成不可弥补的损失。

  3、准考证下载阶段(12月下旬):

  4、考试阶段(1月上旬):

  全国硕士研究生招生考试一般会在每年一份上旬进行,具体考试安排会在中国研究生招生信息网上进行公布,广大考生需提前做好充分的准备,备战联考.

推荐给好友    我要收藏    我要纠错    分享到

免责声明:

① 凡本站注明“稿件来源:中国教育在线”的所有文字、图片和音视频稿件,版权均属本网所有,任何媒体、网站或个人未经本网协议授权不得转载、链接、转贴或以其他方式复制发表。已经本站协议授权的媒体、网站,在下载使用时必须注明“稿件来源:中国教育在线”,违者本站将依法追究责任。

② 本站注明稿件来源为其他媒体的文/图等稿件均为转载稿,本站转载出于非商业性的教育和科研之目的,并不意味着赞同其观点或证实其内容的真实性。如转载稿涉及版权等问题,请作者在两周内速来电或来函联系。

商学院查找
地区
费用
性质
分数线
学校
eol.cn简介 | 联系方式 | 网站声明 | 招聘信息 | 京ICP证140769号 | 京ICP备12045350号 | 京网文[2014]2106-306号 | 京公网安备 11010802020236号
版权所有 新利18luck打不开 CERNET Corporation
Mail to: webmaster@cernet.com