我是Storm的新手，我创建了一个程序来读取一定时间内递增的数字。我在Spout和“nextTuple()”方法中使用了一个计数器，该计数器正在发出并递增_collector.emit(newValues(newInteger(currentNumber++)));/*howthismethodisbeingcontinuouslycalled...*/并且在元组类的execute()方法中有publicvoidexecute(Tupleinput){intnumber=input.getInteger(0);logger.info("Thisnumberis("+number+")"