获取Storm集群上TridentWordCount计算结果的方法

因为Storm集群上的拓扑是持续计算的,不像Hadoop会在HDFS上保存计算结果,由于对于提交到集群上的拓扑而言,须要用户在写程序的时候指定计算结果的输出位置,好比数据库或者本地文件,在运行TridentWordCount的时候,会设置一个DRPCStream来查询Trident的状态,从而能够查询某些单词的统计结果,因为storm-starter中的例子只给了在本地模式下使用localDRPC
相关文章
相关标签/搜索