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!
