95-235-070-源碼-task-OneInputStreamTask

2.概述 ​ 對於 OneInputStreamTask，它的主要執行邏輯就是不斷循環調用 StreamInputProcessor.processInpt() 方法。 ​ StreamInputProcessor 從緩衝區中讀取記錄或 watermark 等消息，然後調用 streamOperator.processElement(record) 交給 head operator 進行處理，並依

>>阅读原文<<