文件名称:编写Storm程序-Hadoop,Hive,Hbase等框架详解
文件大小:3.06MB
文件格式:PPT
更新时间:2024-05-16 04:04:20
Hadoop Hive Spark Hbase
编写Storm程序 基于Storm的单词统计在形式上与基于MapReduce的单词统计是类似的,MapReduce使用的是Map和Reduce的抽象,而Storm使用的是Spout和Bolt的抽象 Storm进行单词统计的整个流程: 从Spout中发送Stream(每个英文句子为一个Tuple) 用于分割单词的Bolt将接收的句子分解为独立的单词,将单词作为Tuple的字段名发送出去 用于计数的Bolt接收表示单词的Tuple,并对其进行统计 输出每个单词以及单词出现过的次数 程序任务:单词统计