Guava provides cachestats out of the box, we found it pretty useful..
Other than that, you are right, we are just using it as plain old k/v map
Cheers, /Manish


On 12/21/17 8:55 PM, Stephen Powis wrote:
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] <mailto:[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_SECSin 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]
    <mailto:[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?




Reply via email to