初步接觸storm(二)----RollingTopWords中如何定時的

又看了一下RollingTopWords,讓我比較關注的地方是在RollingCountBolt類裏,是經過方法TupleHelpers.isTickTuple(tuple)來判斷是否應該發射當前窗口數據,可是判斷的依據一開始讓我很迷惑,竟然是判斷該tuple是否來源於「__system」的組件和「__tick」流。 做爲對storm瞭解很少的人,我真的糊塗了,tuple不都是上游的spout發射
相關文章
相關標籤/搜索