Spout的實現(xiàn)步驟：

• 對文件的改變進行分開的監(jiān)聽，并監(jiān)視目錄下有無新日志文件添加。
• 在數(shù)據(jù)得到了字段的說明后，將其轉換成tuple。
• 聲明Spout和Bolt之間的分組，并決定tuple發(fā)送給Bolt的途徑。

Spout的具體編碼在Listing Three中顯示。

Listing Three：Spout中open、nextTuple和delcareOutputFields方法的邏輯。

1. public void open( Map conf, TopologyContext context,SpoutOutputCollector collector )   
2. {   
3.            _collector = collector;   

4.  10/47   首頁 上一頁 8 9 10 11 12 13 下一頁 尾頁