例如，假设您正在使用 Storm 来聚合网络访问的开始和结束日期。会话从用户第一次访问开始，并在该用户 30 分钟不活动后结束。这些数据在收集时会实时传输到 Storm 中。您如何告诉 Storm 在 30 分钟不活动后发出数据？
我不确定，但你可以TOPOLOGY_TICK_TUPLE_FREQ_SECS在风暴中寻找房产。正如在这篇文章中发现的
\n\n\n勾选元组：通常需要一个 Bolt 以固定的时间间隔执行某些操作，例如刷新写入数据库。许多人一直在使用 ClockSpout 的变体来发送这些报价。ClockSpout 的问题在于，您无法在 Bolt 中内化对刻度的需求，因此，如果您忘记在拓扑中正确设置 Bolt，它将无法正常工作。0.8.0 引入了新的 \xe2\x80\x9tick 元组\xe2\x80\x9d 配置，可让您通过 \xe2\x80\x9ctopology.tick.tuple.freq.secs 指定接收刻度元组的频率\xe2\x80\x9d 特定于组件的配置，然后您的 Bolt 将以该频率从 __system 组件和 __tick 流接收一个元组。
\n
您还可以找到示例代码来配置 spouts 或 Bolt 以接收具有特定间隔的刻度元组。
\n| 归档时间： |
|
| 查看次数： |
2379 次 |
| 最近记录： |