But in my use case, I want to get the Queue size access in Base Stateful bolt. btw thanks .
On Fri, Mar 3, 2017 at 2:18 PM, Sree V <sree_at_ch...@yahoo.com> wrote: > try this, https://github.com/verisign/storm-graphite > set up a graphite server on your local. > register as metrics consumer. > > > > Thanking you. > With Regards > Sree > > > On Friday, March 3, 2017 12:00 AM, anshu shukla <anshushuk...@gmail.com> > wrote: > > > 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 > > > -- Thanks & Regards, Anshu Shukla
