Versions Compared

Old Version 17

changes.mady.by.user Chesnay Schepler

Saved on

compared with

New Version 18

changes.mady.by.user Hang Ruan

Saved on

Key

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

...

3) When a record is matched by RecordEvaluator::isEndOfStream(...), SourceReaderBase stops emitting records from this split and informs SplitFetcherManager to stop reading this split.

4) For SQL users, a new connector option 'scan.record.evaluator.class' is added to provide the custom RecordEvaluator class.

Similar workflow can be made to support this feature for PulsarSource.

...