Storm 第三章 Storm編程案例及Stream Grouping詳解

1 功能說明 　　設計一個topology，來實現對文檔裏面的單詞出現的頻率進行統計。整個topology分爲三個部分： 　　SentenceSpout：數據源，在已知的英文句子中，隨機發送一條句子出去。 　　SplitBolt：負責將單行文本記錄（句子）切分成單詞 　　CountBolt：負責對單詞的頻率進行累加 2 代碼實現 1 package com.ntjr.bigdata; 2

>>阅读原文<<