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

2.概述

​ 对于 OneInputStreamTask，它的主要执行逻辑就是不断循环调用 StreamInputProcessor.processInpt() 方法。

​ StreamInputProcessor 从缓冲区中读取记录或 watermark 等消息，然后调用 streamOperator.processElement(record) 交给 head operator 进行处理，并依次将处理结果交给下游算子。