词频统计

完整源码

需求：

读取指定目录的数据，并实现单词计数功能

实现方案：

1. Spout来读取指定目录的数据，作为后续Bolt处理的input
2. 使用一个Bolt把input的数据，切割开，我们按照逗号进行分割
3. 使用一个Bolt来进行最终的单词次数统计操作
4. 输出

- 阅读剩余部分 -

求和案例

完整源码

需求：

1+2+3+4+5+6+....=???

实现方案：

Spout发送数据作为input
使用Bolt来处理业务：求和
将结果输出到控制台

- 阅读剩余部分 -

ISpout接口

概述

​ 核心接口（interface），负责将数据发送到topology中去处理。
​ Storm会跟踪Spout发出去的tuple的DAG
​ ack/fail
​ tuple：message id （每一次发出去的tuple都有一个messageid，保证如果错误的话messageId可以回传）
​ ack/fail/nextTuple 是在同一个线程中执行的，所以不用考虑线程安全

- 阅读剩余部分 -

环境版本：

• JDK：1.8
• IDEA：2019.1-3
• Maven：3.3.9
• Windows10

- 阅读剩余部分 -

核心概念

• 1. Topologies

  拓扑，将整个流程串起来 （想象成某品牌的流水线）

• 1. Streams

  流，数据流，水流

• 1. Spouts

- 阅读剩余部分 -