zhijiang created FLINK-14004:
--------------------------------
Summary: Define SourceReader interface to verify the integration
with StreamOneInputProcessor
Key: FLINK-14004
URL: https://issues.apache.org/jira/browse/FLINK-14004
Project: Flink
Issue Type: Sub-task
Components: Runtime / Task
Reporter: zhijiang
Assignee: zhijiang
We already refactored the task input and output sides based on the new source
characters in FLIP-27. In order to further verify that the new source reader
could work well with the unified StreamOneInputProcessor in mailbox model, we
would design a unit test for integrating the whole process. In detail:
* Define SourceReader and SourceOutput relevant interfaces based on FLIP-27
* Implement an example of stateless SourceReader (bounded sequence of integers)
* Define SourceReaderOperator to integrate the SourceReader with
StreamOneInputProcessor
* Define SourceReaderStreamTask to execute the source input and implement a
unit test for it.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
