楼主: ReneeBK
843 4

[Github]Apache Storm Applications [推广有奖]

  • 1关注
  • 62粉丝

VIP

已卖：4895份资源

学术权威

14%

还不是VIP/贵宾

-

TA的文库  其他...

R资源总汇

Panel Data Analysis

Experimental Design

0%
威望
1 级
论坛币
49629 个
通用积分
55.4465
学术水平
370 点
热心指数
273 点
信用等级
335 点
经验
57805 点
帖子
4005
精华
21
在线时间
582 小时
注册时间
2005-5-8
最后登录
2023-11-26
楼主
ReneeBK 发表于 2017-8-22 00:38:26 |AI写论文

+2 论坛币
k人 参与回答

经管之家送您一份

应届毕业生专属福利!

求职就业群
赵安豆老师微信：zhaoandou666

经管之家联合CDA

送您一个全额奖学金名额~ !

立即领取

感谢您参与论坛问题回答

经管之家送您两个论坛币！

+2 论坛币
Apache Storm Applications

A collection of real-time applications built with Apache Storm.

Table of Contents
二维码

扫码加我 拉你入群

请注明：姓名-公司-职位

以便审核进群资格，未注明则拒绝

分享0
关键词：Applications Application GitHub cation apache

相关帖子

本帖被以下文库推荐
沙发
ReneeBK 发表于 2017-8-22 00:39:18
  1. package storm.applications.bolt;

  3. import backtype.storm.tuple.Tuple;
  4. import backtype.storm.tuple.Values;
  5. import org.slf4j.Logger;
  6. import org.slf4j.LoggerFactory;
  7. import storm.applications.model.cdr.CallDetailRecord;
  8. import static storm.applications.constants.VoIPSTREAMConstants.*;

  10. /**
  11. *
  12. * @author Maycon Viana Bordin <mayconbordin@gmail.com>
  13. */
  14. public class ACDBolt extends AbstractScoreBolt {
  15.     private static final Logger LOG = LoggerFactory.getLogger(ACDBolt.class);
  16.    
  17.     private double avg;

  19.     public ACDBolt() {
  20.         super("acd");
  21.     }

  23.     @Override
  24.     public void execute(Tuple input) {
  25.         Source src = parseComponentId(input.getSourceComponent());
  26.         
  27.         if (src == Source.GACD) {
  28.             avg = input.getDoubleByField(Field.AVERAGE);
  29.         } else {
  30.             CallDetailRecord cdr = (CallDetailRecord) input.getValueByField(Field.RECORD);
  31.             String number  = input.getString(0);
  32.             long timestamp = input.getLong(1);
  33.             double rate    = input.getDouble(2);

  35.             String key = String.format("%s:%d", number, timestamp);

  37.             if (map.containsKey(key)) {
  38.                 Entry e = map.get(key);
  39.                 e.set(src, rate);

  41.                 if (e.isFull()) {
  42.                     // calculate the score for the ratio
  43.                     double ratio = (e.get(Source.CT24)/e.get(Source.ECR24))/avg;
  44.                     double score = score(thresholdMin, thresholdMax, ratio);
  45.                     
  46.                     LOG.debug(String.format("T1=%f; T2=%f; CT24=%f; ECR24=%f; AvgCallDur=%f; Ratio=%f; Score=%f",
  47.                         thresholdMin, thresholdMax, e.get(Source.CT24), e.get(Source.ECR24), avg, ratio, score));

  49.                     collector.emit(new Values(number, timestamp, score, cdr));
  50.                     map.remove(key);
  51.                 } else {
  52.                     LOG.warn(String.format("Inconsistent entry: source=%s; %s",
  53.                             input.getSourceComponent(), e.toString()));
  54.                 }
  55.             } else {
  56.                 Entry e = new Entry(cdr);
  57.                 e.set(src, rate);
  58.                 map.put(key, e);
  59.             }
  60.         }
  61.     }
  62.    
  63.     @Override
  64.     protected Source[] getFields() {
  65.         return new Source[]{Source.CT24, Source.ECR24};
  66.     }
  67. }
复制代码
藤椅
MouJack007 发表于 2017-8-22 07:36:49
谢谢楼主分享！
板凳
MouJack007 发表于 2017-8-22 07:37:05

报纸
西门高 发表于 2017-8-22 18:53:57
谢谢分享
返回列表
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 我要注册

本版微信群
加好友,备注jltj
拉您入交流群

京ICP备16021002号-2 京B2-20170662号 京公网安备 11010802022788号 论坛法律顾问：王进律师 知识产权保护声明   免责及隐私声明

GMT+8, 2025-12-6 02:46