Thank you very much for the above replies! They are very helpful.
2014-03-08 15:30 GMT+01:00 Sean Allen <[email protected]>: > You can run into trouble trying to get a fixed time interval. > > If you haven't processed enough of the previous tuples, you can bring your > topology to a halt. > Proceed with caution. > > > On Wed, Mar 5, 2014 at 2:28 PM, 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! >> > > > > -- > > Ce n'est pas une signature >
