Smart Grid
是一种没有状态的应用,因为是每个小时就刷新,重新计算。但是可以测试ACK机制的影响,因为窗口没计算完成的时候,是不会ACK窗口内的tuple 的。不同窗口的大小,缓存的tuple数目不同。
Spamfilter
解析统计字,sum,然后发送给表bolt,统计更新字的概率,可多并行度,因为按字的key各自维护,但是sum变量是每个表中共享的,需要及时更新,所以使用allgroup来传播sum,这样多并行度的表都能收到最新的sum,然后也在表bolt中获取分析所需要的字,也按key来传播分析字的,这样分析的字就能在有key的表bolt上查找,查出所需的字后发给按邮件ID计算的贝叶斯bolt来接收word来统计计算概率。
网友评论