大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
本篇内容介绍了“storm实时排序TopN怎么使用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
10年积累的成都网站建设、网站设计经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站设计后付款的网站建设流程,更有荣昌免费网站建设让你可以放心的选择与我们合作。
阅读背景:1 您需要了解TOP 使用的场景
2 您需要了解当前的TOPN 处理,和定时区间处理的区别
看代码说话
package com.cc.storm; import com.cc.storm.bolt.MergeBolt; import com.cc.storm.bolt.RankBolt; import com.cc.storm.bolt.RollingAllCountBolt; import com.cc.storm.bolt.RollingCountBolt; import com.cc.storm.spout.RandomEmitSpout; import com.cc.storm.spout.redisPubSubSpout; import backtype.storm.Config; import backtype.storm.LocalCluster; import backtype.storm.StormSubmitter; import backtype.storm.generated.AlreadyAliveException; import backtype.storm.generated.InvalidTopologyException; import backtype.storm.topology.TopologyBuilder; import backtype.storm.tuple.Fields; /** * ToPN是一种常见模式,是对流式数据进行“Streaming topN”的计算: * 比如要计算的是最近一段时间内的热门话题,热门点击图片,热门商品浏览,热门商品购买 * * 既然敢要实时的处理,【】【】【】【】【】[] 【】 【】【】【】【】 [] 【】【】【】【】 【】 [] * * @author Yin Shuai */ public class TOP10 { public static void main(String[] args) throws AlreadyAliveException, InvalidTopologyException, InterruptedException { final int TOP_N = 10; final int time = 1; TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("$datasource$", new RandomEmitSpout(), 1); builder.setBolt("$count$", new RollingCountBolt(3, time), 1) .fieldsGrouping("$datasource$", new Fields("merchandiseIDS")); builder.setBolt("$rank$", new RankBolt(TOP_N), 2).fieldsGrouping( "$count$", new Fields("merchandiseID")); builder.setBolt("$merge$", new MergeBolt(TOP_N)).globalGrouping( "$rank$"); Config conf = new Config(); conf.setDebug(false); conf.setNumWorkers(2); conf.setMaxSpoutPending(5000); LocalCluster cluster = new LocalCluster(); cluster.submitTopology("Getting-Started-Toplogie", conf, builder.createTopology()); Thread.sleep(5000); } }
整个处理的流程如图:
“storm实时排序TopN怎么使用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!