pnowojski commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-538887514 I had a chat with @StephanEwen and a proposal to unblock this is to avoid defining `SourceReader` interface here. We can just implement the `SourceReaderOperator` class, as a for example a stateful/stateless infinite/finite source of integers. We could integrate it with the runtime and it would be generating the integers and emitting them directly to the `DataOutput`. Later, someone implementing a final `SourceReader` interface would just reimplement `SourceReaderOperator` to use `SourceReader` interface. More specifically, we could just drop the `SourceReader` interface from this PR, embed the logic of `TestingFiniteSourceReader` inside the `SourceReaderOperator` and that should be it. The following would be to implement state snapshotting in this `SourceReaderOperator` (to test our integration with stateful readers).
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
