1. 程式人生 > >Hadoop 面試題之storm (3)

Hadoop 面試題之storm (3)

 storm怎麼完成對單詞的計數?(個人看完storm 後一直都認為他是流處理,好像沒有積攢資料的能力,都是處理完之後直接分發給下一個元件)

【SplitBolt接收SentenceSpout發射的tuple,它將每句話分割成每個單詞,並將每個單詞作為tuple發射。再次,WordCountBolt接收SplitBolt傳送的tuple,它將接收到的每一個單詞統計計數,並將 <單詞:出現次數> 作為tuple發射。最後,ReportBolt接收WordCountBolt傳送的tuple,將統計的結果存入HashMap中,並打印出結果。】