[FLINK-15100] Add the interface and base implementation for SourceReader.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 06/Dec/19 12:14
• Updated: 29/Mar/20 14:03
• Resolved: 28/Mar/20 14:51

Description

Add the interface and base implementation for SourceReader. Including threading model, SplitReader / RecordEmitter. This ticket should also integrate the SourceReader into the SourceReaderStreamTask.

Issue Links

• links to: GitHub Pull Request #10487