We added a guava cache in the bolt's execute method to aggregate tuples and wait for the tick signal.
You can control the tick frequency with TOPOLOGY_TICK_TUPLE_FREQ_SECS in the main topology. This is a Spark use case IMO. cheers, /Manish On Wed, Dec 20, 2017 at 9:09 PM, Jinhua Luo <[email protected]> wrote: > Hi All, > > The window may buffer many tuples before evaluation, does storm > support incremental aggregation upon the window, just like flink does? >
