How would you pick storm data after a certain period of time?

For example, you could say that you used a storm to aggregate the start and end dates of a web visit. A session begins with the user's first visit and ends after 30 minutes of inactivity from the same user. This data is transmitted to the storm in real time as it is collected. How would you say that a storm would give out data after this 30 minutes of inactivity?

+4
source share
1 answer

I'm not sure, but you can search for properties TOPOLOGY_TICK_TUPLE_FREQ_SECSin a storm. As stated in this article

Tick tuples: , , " -" , , flush . ClockSpout . ClockSpout , , , , . 0.8.0 "tick tuple", , -, "topology.tick.tuple.freq.secs", __ __tick- .

.

+2

All Articles