Почему я не должен зацикливаться или блокироваться в Spout.nextTuple ()

Я видел много фрагментов кода, в которых внутри был использован цикл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(), Вопрос почему?

Ответы на вопрос(1)

Ваш ответ на вопрос