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