[jira] [Created] (FLINK-13766) Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

[Shang Yuanchun (Jira)]

zhijiang created FLINK-13766:
--------------------------------

             Summary: Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext
                 Key: FLINK-13766
                 URL: https://issues.apache.org/jira/browse/FLINK-13766
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Task
            Reporter: zhijiang
            Assignee: zhijiang


The current processing in task input processor is based on the way of pollNext. In order to unify the processing way of new source operator, we introduce the new StreamTaskInput#emitNext(Output) instead of current pollNext. Then we need to adjust the existing implementations of StreamOneInputProcessor/StreamTwoInputSelectableProcessor based on the new emit way.

To do so, we could integrate all the task inputs from network/source in a unified processing on runtime side.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)