Bolt的实现
Spout的输出结果将给予Bolt进行更深一步的处理。经过对用例的思考,我们的topology中需要如Figure 3中的两个Bolt。
Figure 3:Spout到Bolt的数据流程。
ThresholdCalculatorBolt
Spout将tuple发出,由ThresholdCalculatorBolt接收并进行临界值处理。在这里,它将接收好几项输入进行检查;分别是:
临界值检查
- 临界值栏数检查(拆分成字段的数目)
- 临界值数据类型(拆分后字段的类型)
- 临界值出现的频数
- 临界值时间段检查
Listing Four中的类,定义用来保存这些值。