相关疑难解决方法(0)

我看到很多代码片段里面都使用了一个循环Spout.nextTuple()(例如读取整个文件并为每一行发出一个元组):

public void nextTuple() {
    // do other stuff here

    // reader might be BufferedReader that is initialized in open()
    String str;
    while((str = reader.readLine()) != null) {
        _collector.emit(new Values(str));
    }

    // do some more stuff here
}

这段代码似乎是直截了当的,然而,我被告知不应该循环内部nextTuple().问题是为什么？