jackylee-ch opened a new pull request, #1040: URL: https://github.com/apache/paimon-rust/pull/1040
Adds the `rollback_to_watermark` CALL procedure to the DataFusion integration, mirroring Flink's `RollbackToWatermarkProcedure`: ``` CALL sys.rollback_to_watermark(table => 'db.t', watermark => 1700000000000) ``` It rolls the table back to the latest snapshot whose event-time watermark is at or before the given value, discarding newer ones. This completes the rollback family next to `rollback_to` (snapshot/tag) and `rollback_to_timestamp` (commit time); watermark rollback targets event time rather than wall-clock commit time. The procedure needs `SnapshotManager::earlier_or_equal_watermark`, the mirror of the existing `later_or_equal_watermark`, added here for parity with Java `SnapshotManager.earlierOrEqualWatermark`. Verified with new `earlier_or_equal_watermark` unit tests and a procedure test; `fmt` and `clippy --all-targets -D warnings` clean. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
