Thanks for your advice! But my double still remains. Is the nextTuple method called only when the previous tuples are acked in the ack method? Anyone knows the internal strategy?
Thx! Best, 2014-03-06 8:14 GMT+01:00 James Xu <[email protected]>: > use Tick Tuple. > > On 2014年3月6日, at 上午4:28, Tian Guo <[email protected]> wrote: > > I am developing some data analysis algorithms on top of Storm and have > some questions about the internal design of Storm. > > I want to simulate a sensor data yielding and processing in Storm, and > therefore I use Spout to push sensor data into the succeeding bolts at a > constant time interval via setting a sleep method in nextTuple method of > Spout. But from the experiment results, it appeared that spout didn't push > data at the specified rate. In the experiment, there was no bottleneck bolt > in the system. > > Therefore, my doubt is if the nextTuple method is called only when the > previous tuples are fully processed and acked in the ack method? > > If this is true, does it means that I cannot set a fixed time interval to > emit data? > > Thx a lot! > > >
