Is there a reason to use Guava cache to aggregate over just a plain old Map? Curious as aggregation is a common use case for us and never thought to look to Guava for it.
Thanks! On Fri, Dec 22, 2017 at 1:50 PM, Manish Sharma <[email protected]> wrote: > 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? >> > >
