How would you emit storm data after a period of time has lapsed? -


for example, lets using storm aggregate web visit start , end dates. session starts first visit user , ends after 30 minutes of inactivity same user. data being streamed storm in realtime collected. how tell storm emit data after 30 minutes of inactivity?

i not sure can topology_tick_tuple_freq_secs properties in storm. found in this article

tick tuples: it’s common require bolt “do something” @ fixed interval, flush writes database. many people have been using variants of clockspout send these ticks. problem clockspout can’t internalize need ticks within bolt, if forget set bolt correctly within topology won’t work correctly. 0.8.0 introduces new “tick tuple” config lets specify frequency @ want receive tick tuples via “topology.tick.tuple.freq.secs” component-specific config, , bolt receive tuple __system component , __tick stream @ frequency.

you can found sample code configure spouts or bolt receive tick tuple specific interval.


Comments

Popular posts from this blog

javascript - Jquery show_hide, what to add in order to make the page scroll to the bottom of the hidden field once button is clicked -

javascript - Highcharts multi-color line -

javascript - Enter key does not work in search box -