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!
