Versions Compared

Old Version 19

changes.mady.by.user Hongshun Wang

Saved on

compared with

New Version 20

changes.mady.by.user Hongshun Wang

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • To expose the SplitFetcherManager / SingleThreadFetcheManager as Public, allowing connector developers to easily create their own threading models in the SourceReaderBase.
  • Shield FutureCompletingBlockingQueue from users and limit all operations on FutureCompletingBlockingQueue in FetcherManagerTo hide the element queue from the connector developers and simplify the SourceReaderBase to consist of only SplitFetcherManager and RecordEmitter as major components.

Public Interfaces

SplitFetcherManager

...