changliiu

**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...

Add filter to GetMinUnfinishedWatermark queryAdd filter tester

9

To improve the performance of the query for GetUnfinishedMinWatermark, we can add a filter to the query. Note that the query run on a cache to refresh every 1s. We...

Use now + 2mins as the end timestamp for change stream read API if the connector endTimestamp is omitted

8

V1 change stream can use null end timestamp for the query, however V2 the end timestamp of the query should be NOT NULL, and should be at most 30 mins...

Add change stream new record models and tests.

3

Include PartitionStartRecord, PartitionEndRecord, PartitionEventRecord, MoveInEvent, MoveOutEvent. These will be used in the following PRs - the returned change stream record will be parsed into these models, and corresponding actions will...