Dear Flink Developers, Thank you for providing feedback on FLIP-389: Annotate SingleThreadFetcherManager as PublicEvolving[1] on the discussion thread[2]. The goal of the FLIP is as follows:
- To expose the SplitFetcherManager / SingleThreadFetcheManager as Public, allowing connector developers to easily create their own threading models in the SourceReaderBase by implementing addSplits(), removeSplits(), maybeShutdownFinishedFetchers() and other functions. - To hide the element queue from the connector developers and simplify the SourceReaderBase to consist of only SplitFetcherManager and RecordEmitter as major components. Any additional questions regarding this FLIP? Looking forward to hearing from you. Thanks, Hongshun Wang [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=278465498 [2] https://lists.apache.org/thread/b8f509878ptwl3kmmgg95tv8sb1j5987
