95-235-070-源码-task-OneInputStreamTask

2.概述 ​ 对于 OneInputStreamTask，它的主要执行逻辑就是不断循环调用 StreamInputProcessor.processInpt() 方法。 ​ StreamInputProcessor 从缓冲区中读取记录或 watermark 等消息，然后调用 streamOperator.processElement(record) 交给 head operator 进行处理，并依

>>阅读原文<<