例如，假设您正在使用storm来聚合web访问的开始和结束日期。会话从用户的第一次访问开始，并在同一用户的30分钟不活动后结束。这些数据在被收集的过程中被实时传输到storm中。你如何让风暴在30分钟不活动后发出数据?
我不确定，但你可以在风暴中寻找TOPOLOGY_TICK_TUPLE_FREQ_SECS属性。这篇文章
勾号元组:通常需要一个螺栓以固定的间隔"做一些事情"，比如刷新数据库。许多人一直在使用ClockSpout的变体来发送这些滴答声。ClockSpout的问题在于，您无法在螺栓中内化对刻度的需求，因此，如果您忘记在拓扑中正确设置螺栓，它将无法正常工作。0.8.0引入了一个新的"tick tuple"配置，允许你通过"topology.tick.tuple.freq.secs"特定于组件的配置指定你想要接收tick元组的频率，然后你的bolt将以该频率从__system组件和__tick流接收元组。
您还可以找到配置spouts或bolt以接收具有特定间隔的tick元组的样例代码。