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)
Locked
