Bolt的實現(xiàn)
Spout的輸出結(jié)果將給予Bolt進行更深一步的處理。經(jīng)過對用例的思考,我們的topology中需要如Figure 3中的兩個Bolt。
Figure 3:Spout到Bolt的數(shù)據(jù)流程。
ThresholdCalculatorBolt
Spout將tuple發(fā)出,由ThresholdCalculatorBolt接收并進行臨界值處理。在這里,它將接收好幾項輸入進行檢查;分別是:
臨界值檢查
- 臨界值欄數(shù)檢查(拆分成字段的數(shù)目)
- 臨界值數(shù)據(jù)類型(拆分后字段的類型)
- 臨界值出現(xiàn)的頻數(shù)
- 臨界值時間段檢查
Listing Four中的類,定義用來保存這些值。