mohupo 2014-03-26 03:24 采纳率: 0%
浏览 2958

esper如何在storm下进行多线程处理

最近在storm框架下用esper处理一分钟内筛选后数据。
在UpdateListener类内拿到数据（List集合），发现listener针对于同一个newEvents执行了5次。debug后发现listener有五个线程在跑，所以输出了五次。
因为是刚接触esper，所以想问下，这块对于esper在多线程下如何控制listener对于update方法内对于同一个newEvents执行次数问题！
十分感谢！

  • 写回答

1条回答

  • shiter 人工智能领域优质创作者 2015-01-19 12:54
    关注

    http://ju.outofmemory.cn/entry/55225

    评论

报告相同问题？

  • esper计算问题，有会的大神麻烦贴下代码，非常感谢
    2016-04-26 12:03
    回答 9 已采纳 虽然没搞明白你要干嘛, 但是从模糊的描述中我大概差不多知道了你的意思... 贴下代码. 自己吧c1-c50补充完整就可以了. 下面的示例是 1sec 自己改1 min吧 直接可运行
  • Eternal Reality
    2017-04-09 03:07
    回答 1 已采纳 http://www.cnblogs.com/cnox/
  • Laravel Query Builder结果对象抛出“试图获取非对象属性”异常 php
    2016-05-16 15:39
    回答 1 已采纳 As DB::Select wraps around PDO and makes use of the fetchMode property to choose between object or
  • 漫谈大数据第四期-storm
    2013-11-06 14:24
    Storm有一个“本地模式”，可以在处理过程中完全模拟Storm集群。这让你可以快速进行开发和单元测试。 Storm集群由一个主节点和多个工作节点组成。主节点运行了一个名为“Nimbus”的守护进程，用于分配代码、布置任务...
  • Storm整合Springboot
    2019-10-07 00:03
    木木阿木的博客 Storm运行有两种模式，分别是local与remote。因此，Storm与Springboot...local模式整合Springboot，storm与Springboot都运行在同一JVM中，而remote模式整合，Storm的计算节点会在不同的JVM中（跨进程）被初始化并运算。
  • 流处理框架Storm简介
    2013-03-23 23:03
    colorknight的博客 EMC中国研究院 向东  提起Big Data，人们往往会提起大数据的4个V: Volume,Velocity , ...这四个V从各个侧面说明了大数据并不是新瓶装旧酒: 面对数据产生来源，产生方式，处理方式等等一系列质变，原来适用的数
  • 大数据最佳实践-flink
    2021-04-22 10:49
    猿与禅的博客 在这种操作模式下，您可以选择在产生任何结果之前先摄取整个数据集，这意味着，例如，可以对数据进行排序，计算全局统计数据或产生总结所有输入的最终报告。 另一方面，流处理涉及无限的数据流。至少
  • 经典大数据架构案例：酷狗音乐的大数据平台重构
    2022-08-18 09:51
    诸葛钢铁云的博客 大数据
  • 大数据四大阵营之OLTP阵营（上）
    2021-05-26 15:47
    XAI嬴图的博客 ** 一 | 大数据的四大阵营是什么？...· 流数据管理：CEP/Esper、Storm、Spark、Stream、Flume等 二 | OLTP阵营 OLTP阵营可以分为： ·传统的关系型数据库 ·NoSQL ·NewSQL 三类不同的解决方案。 在本篇文章中，我们.
  • 大数据基础概念（二）
    2019-10-09 14:57
    戰士的博客 大数据技术被设计用于在成本可承受的条件下，通过非常快速（velocity）地采集、发现和分析，从大量（volumes）、多类别（variety）的数据中提取价值（value），将是IT领域新一代的技术与架构。 2.数据流架构如图 ...
  • 2020年9月大数据相关面试
    2020-11-18 14:51
    wg_hadoop的博客 3、数据库表a记录了很多用户在很多城市的访问记录， 字段a.user_id, a.city, a.time, a.other_info 使用一条SQL查出每个user_id 在每个city的最后一条访问记录 4、reduceByKey和CombineByKey和aggregateByKey，gr
  • 流处理基本介绍
    2017-01-23 10:14
    Ransom0512的博客 1. 什么是流处理 一种被设计来处理无穷数据集的数据处理系统引擎 2. 流处理的几个概念 1. 无穷数据（Unbounded data）：一种持续生成，本质上是无穷尽的数据集。它经常会被称为“流数据”。然而，用流和批次来...
  • 酷狗音乐的大数据实践
    2019-10-03 16:14
    aebdm757009的博客 此文是根据酷狗音乐大数据架构师王劲在【QCON高可用架构群】中的分享内容整理而成，转发请注明出处。 王劲：目前就职酷狗音乐，大数据架构师，负责酷狗大数据技术规划、建设、应用。 11年的IT从业经验，2年分布式...
  • Storm (分布式的、容错的实时流式计算系统） 基础概念
    2017-03-05 14:35
    ronmy的博客 Storm为分布式实时计算提供了一组通用原语，可被用于“流处理”之中，实时处理消息并更新数据库。这是管理队列及工作者集群的另一种方式。 Storm也可被用于“连续计算”（continuous computation），对数据流做连续...
  • 【图文直播全文记录】酷狗音乐的大数据实践（纯干货）
    2017-02-08 09:47
    scdxmoe的博客 此文是根据酷狗音乐大数据架构师王劲在【QCON高可用架构群】中的分享内容整理而成，转发请注明出处。 王劲：目前就职酷狗音乐，大数据架构师，负责酷狗大数据技术规划、建设、应用。 11年的IT从业经验，2年...
  • 酷狗音乐的大数据平台重构
    2021-01-24 09:14
    淋风沐雨的博客 眨眼就是新的一年了，时间过的真快，趁这段时间一直在写总结的机会，也总结下上一年的工作经验，避免重复踩坑。酷狗音乐大数据平台重构整整经历了一年时间，大头的行为流水数据迁移到新平台稳定运行，在这过程中填过...
  • 没有解决我的问题, 去提问

悬赏问题

  • ¥15 程序不包含适用于入口点的静态Main方法
  • ¥15 素材场景中光线烘焙后灯光失效
  • ¥15 请教一下各位，为什么我这个没有实现模拟点击
  • ¥15 执行 virtuoso 命令后，界面没有，cadence 启动不起来
  • ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置
  • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
  • ¥15 ubuntu子系统密码忘记