獲取Storm集羣上TridentWordCount計算結果的方法

因爲Storm集羣上的拓撲是持續計算的，不像Hadoop會在HDFS上保存計算結果，由於對於提交到集羣上的拓撲而言，須要用戶在寫程序的時候指定計算結果的輸出位置，好比數據庫或者本地文件，在運行TridentWordCount的時候，會設置一個DRPCStream來查詢Trident的狀態，從而能夠查詢某些單詞的統計結果，因爲storm-starter中的例子只給了在本地模式下使用localDRPC

>>阅读原文<<