實作了一個簡單的從實時日志檔案監聽,寫入socket伺服器,再接入Storm計算的一個流程。
最後執行
spout接受從socket伺服器實時發送過來的資料,經過topology處理,最終将資料寫入out_socket.txt檔案
本文轉自ljianbing51CTO部落格,原文連結:http://blog.51cto.com/ljianbing/1733313 ,如需轉載請自行聯系原作者
實作了一個簡單的從實時日志檔案監聽,寫入socket伺服器,再接入Storm計算的一個流程。
最後執行
spout接受從socket伺服器實時發送過來的資料,經過topology處理,最終将資料寫入out_socket.txt檔案
本文轉自ljianbing51CTO部落格,原文連結:http://blog.51cto.com/ljianbing/1733313 ,如需轉載請自行聯系原作者