Thanks! On Fri, Mar 3, 2017 at 7:28 AM, Jungtaek Lim <kabh...@gmail.com> wrote:
> No you need to look at here: storm-core/src/jvm/org/apache/ > storm/utils/DisruptorQueue.java > > It also has QueueMetrics for expose queue metrics to metrics consumers. > > Hope it helps. > > Thanks, > Jungtaek Lim (HeartSaVioR) > > On Thu, 2 Mar 2017 at 9:02 PM anshu shukla <anshushuk...@gmail.com> wrote: > >> Hello, >> >> I want to *find the send and receive Queue size *used by the LMAX >> Disruptor. >> But I am worried that while accessing the call hierarchy of the execute >> function in storm-starter code with StatefulSumBolt the end point to the >> Queue is : >> >> KeyedRoundRobinQueue<Tuple> _rrQueue; >> >> in *package org.apache.storm.drpc;* >> >> *I am worrying is it the right place i should look in to ? I have >> attached the screenshot for that.* >> >> -- >> Thanks & Regards, >> Anshu Shukla >> > -- Thanks & Regards, Anshu Shukla
