Sorry, maybe what I posted was a little confusing. The linked file is the wrapper Storm has around the real Disruptor queue. You can open the Storm project and take a look at that class and where it is used, and get answers to your questions.
Den fre. 6. sep. 2019 kl. 17.01 skrev Nithin Uppalapati (BLOOMBERG/ 731 LEX) <[email protected]>: > Hi, > > I want to understand how and where the disruptor queue is used. > > From: [email protected] At: 09/06/19 10:47:39 > To: [email protected] > Subject: Re: Topology Disruptor Batch Size > > I'm not aware of any documentation on it. The Disruptor implementation was > replaced as of Storm 2.0.0 with JCTools queues. You can find documentation > on that here https://issues.apache.org/jira/browse/STORM-2306 > > If you want to read the code around the Disruptor queue, > https://github.com/apache/storm/blob/v1.2.3/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java > is a good place to start. > > Den fre. 6. sep. 2019 kl. 15.41 skrev Nithin Uppalapati (BLOOMBERG/ 731 > LEX) <[email protected]>: > >> Hi, >> >> Is there some documentation around TOPOLOGY.DISRUPTOR.BATCH.SIZE, I could >> not find any good blogs or documentation around it. >> >> I could understand well about executor and worker process internal buffer >> queue's and their role. Would like to understand similarly about disruptor >> batch size and timeouts. >> >> Thanks, Nithin >> > >
