此项目不再维护 有关最新信息,请参阅 。 Storm-kafka-hdfs-starter 提供使用 KafkaSpout 和 HdfsBolt 的示例
2021-07-02 11:03:08 28KB Java
1
ZooKeeper 用于管理集群中的不同组件,ØMQ 是内部消息系统,JZMQ 是 ØMQ 的 Java Binding。ZeroMQ 是用 C++编写的,而 jzmq 就充当了 Java 与 C++之间的桥梁。ZeroMQ的安装包,本人上传也有资源。
2021-06-24 15:45:34 153KB storm jzmq zookeeper
1
Apache Storm是一个分布式实时大数据处理系统。Storm设计用于在容错和水平可扩展方法中处理大量数据。
2021-06-23 13:05:48 464KB storm
1
-_11.11_storm-spark-hadoop hadoop_storm_spark结合实验的例子,模拟淘宝双11节,根据订单详细信息,汇总出总销售量,各个省份销售排行,以及后期SQL分析,数据分析,数据挖掘等。 --------大概流程------- 第一阶段(storm实时报表) (1)用户订单入kafka队列, (2)经过storm,实时计算出总销售量,和各个省份的的销售量, (3)将计算结果保存到hbase数据库中。 第二阶段(离线报表) (1)用户订单入oracle数据库, (2)通过sqoop把数据导入hadoop上。 (3)使用mr和rdd对hadoop上的原始订单做etl清洗 (4)建立hive表和sparkSQL内存表。为后期分析做基础 (5)使用HQL实现业务指标分析,和用户画像分析,将结果存在mysql中。供web前台使用 第三阶段(大规模订单即席查询,和多维度
2021-06-22 15:04:33 26KB Java
1
storm实验报告
2021-06-19 09:07:04 569KB storm
1
2015 年营地 Apache Storm 入门 为 2015 年 BreizhCamp 的 Start with Apache Storm 会议创建的项目。 羊柜台 Sheep-counter 是一种 Storm 拓扑,用于按发送到 Redis pub/sub 的羊的颜色进行排序和计数。 要启动它: 运行bzh.cjuste.breizhcamp.sheepcounter.SheepCounterTopology类 等待消息Ready to receive messages ! 运行测试类(在 src/test/java 中) bzh.cjuste.breizhcamp.sheepcounter.SendSheeps
2021-05-31 19:03:43 110KB Java
1
storm实现井字棋游戏源码, 详情见博文:http://blog.csdn.net/l1028386804/article/details/79149418
2021-05-18 22:23:42 61KB storm 井字棋游戏
1
apache-atlas-2.1.0-storm-hook.tar.gz--基于cdh6.3.1编译完成
2021-05-10 14:05:29 52.97MB atlas2.1.0 cdh6.3.1 storm storm-hook
1
本项目主要实现了首先通过python编写的爬虫程序,对今日头条的新闻进行爬取,爬取的内容相对丰富,内容,图片都有爬取,另外,将获取到的新闻进行了实体分析,用textrank图算法计算了关联程度,得到了每篇新闻的一个关键词,高频词,实体对象的力引导图,同时结合大数据流处理的storm技术,在进行实体分析的同时进行了新闻数据的存储,即新闻数据的持久化,整个项目比较有学习价值,欢迎大家下载
2021-05-10 07:29:45 27.22MB python ltp实体分析 storm流处理 kafka
1
这是书籍Getting started with Storm的中英文两个版本,大家可以参考对照学习哦
2021-04-10 12:31:15 3.44MB 实时大数据
1