AI 助理
备案控制台
开发者社区 大数据 文章 正文

Storm之LocalCluster.clj

2015-12-17 2875
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

       此类初始化了一些配置参数，实现了ILocalCluster接口，将拓扑结构提交到nimbus，最终通过nimbus来执行

其中最重要的看


gen-class中定义了init的函数名为”init”，继承了ILocalCluster接口

下面看init函数：


定义了3种init函数

  1. 无参数 设置了TOPOLOGY-ENABLE-MESSAGE-TIMEOUTS，返回ret作为state
  1. String 和 Long 两个参数，分别制定zookeeper的Host和Port，返回ret作为state
  1. java中的Map，直接返回，将map当做state
文章标签：
Java
流计算
子沭
目录
相关文章
周盛欢
|
9月前
|
存储 Java Linux
Storm详细配置
Storm详细配置
周盛欢
113 0
阿甘兄
|
存储 消息中间件 分布式计算
104 Storm介绍
104 Storm介绍
阿甘兄
52 0
大数据流动
|
消息中间件 分布式计算 资源调度
Spark Streaming，Flink，Storm，Kafka Streams，Samza：如何选择流处理框架
根据最新的统计显示，仅在过去的两年中，当今世界上90％的数据都是在新产生的，每天创建2.5万亿字节的数据，并且随着新设备，传感器和技术的出现，数据增长速度可能会进一步加快。从技术上讲，这意味着我们的大数据处理将变得更加复杂且更具挑战性。而且，许多用例（例如，移动应用广告，欺诈检测，出租车预订，病人监护等）都需要在数据到达时进行实时数据处理，以便做出快速可行的决策。这就是为什么分布式流处理在大数据世界中变得非常流行的原因。
大数据流动
185 0
Spark Streaming，Flink，Storm，Kafka Streams，Samza：如何选择流处理框架
看山灬
|
存储 监控 安全
storm笔记：storm集群
Strom集群结构是有一个主节点（nimbus）和多个工作节点（supervisor）组成的主从结构，主节点通过配置静态指定（还有一种主从结构是在运行时动态选举，比如zookeeper）。通常这种主从结构存在出现单点故障的风险，Storm通过特殊处理规避这种风险，后面将解释Storm的半容错结构。
看山灬
449 0
storm笔记：storm集群
学堂小助手
|
开发框架 分布式计算 Java
storm 介绍|学习笔记
快速学习 storm 介绍
学堂小助手
167 0
storm 介绍|学习笔记
看山灬
|
消息中间件 JSON 自然语言处理
storm笔记：Storm+Kafka简单应用
通过本文记录一下这种情况，后文中根据上述场景提供几个简单的例子。因为是初学storm、kafka，基础理论查看storm笔记：storm基本概念，，或查看Storm 简介。
看山灬
199 0
开发者说
Storm BaseBasicBolt和BaseRichBolt
Storm BaseBasicBolt和BaseRichBolt
开发者说
861 0
开发者说
|
流计算 jstorm
Jstorm vs Storm
Jstorm 是由Storm演化而来，在架构和实现上都有很大的相似度，并且沿用了Storm的编程接口，Storm的程序在很多版本上，可以无缝迁移到Jstorm。整体上说，Jstorm更稳定，灵活性更高，性能更高。
开发者说
1311 0
友德
|
存储 分布式计算 Java
Storm学习总结
友德
2671 0
wsc449
|
分布式计算 Hadoop 流计算
Storm
应用场景 1.信息流处理 Storm可用来实时处理新数据和更新数据库，兼具容错性和可扩展性。即 Storm可以用来处理源源不断流进来的消息，处理之后将结果写入到某个存储中去。
wsc449
1389 0

热门文章

最新文章

  • 1
    解决kafka集群由于默认的__consumer_offsets这个topic的默认的副本数为1而存在的单点故障问题
  • 2
    使用 Docker 高效搭建本地开发环境（详细教程）
  • 3
    如何使用java代码导出word
  • 4
    《Python编程从0到1》笔记1——表达式的风格（前缀、中缀、后缀）
  • 5
    Nginx目录文件列表显示
  • 6
    中移动与阿里巴巴将在四大领域展开全面战略合作
  • 7
    mysql 主从复制配置
  • 8
    google guice @inject comments
  • 9
    html页面中event的常见应用
  • 10
    微软要在年内推出IPTV平台 抢占客厅市场
  • 1
    一级倒立摆平衡控制系统MATLAB仿真,可显示倒立摆平衡动画,对比极点配置,线性二次型,PID,PI及PD五种算法
    28
  • 2
    基于SOA海鸥优化算法的三维曲面最高点搜索matlab仿真
    34
  • 3
    基于PI控制的三相整流器控制系统的simulink建模与仿真,包含超级电容充电和电机
    42
  • 4
    MCMS：Star 28.1k,还在为CMS系统发愁？这款开源神器让内容管理变得像搭积木一样简单！
    35
  • 5
    XJ-Survey：这个让滴滴日均处理1.2亿次问卷请求的开源系统，今天终于公开了它的架构密码！
    37
  • 6
    CPU can only see the threads
    26
  • 7
    Java+机器学习基础：打造AI学习基础
    43
  • 8
    使用 pipx 安装并执行 Python 应用程序 (1)
    36
  • 9
    国产AI神器Deepseek，本地离线使用教程！
    56
  • 10
    短视频创作助手 | AI剧本生成与动画创作
    152

    • 相关课程

    更多
  • Hadoop 分布式计算框架 MapReduce
  • Apache Flink 入门
  • 快速掌握阿里云 E-MapReduce
  • Apache Flink 入门到实战 - Flink开源社区出品
  • Hadoop 分布式资源管理框架 YARN
  • E-MapReduce入门

    • 相关电子书

    更多
  • Flink+HBase场景化解决方案
  • Streaming Lakehouse Meetup
  • 《Apache Flink-实时即未来》
    • 下一篇
    PAI Model Gallery 支持云上一键部署 DeepSeek-V3、DeepSeek-R1 系列模型