From 1f7fb5fb8b043ec0eefff13cb4f8c76a6e939169 Mon Sep 17 00:00:00 2001 From: discord9 <55937128+discord9@users.noreply.github.com> Date: Fri, 14 Aug 2026 09:32:10 +0800 Subject: [PATCH] feat(flow): expose checkpoint persistence constants Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com> --- src/flow/src/lib.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/flow/src/lib.rs b/src/flow/src/lib.rs index e55e7bab76..d32b7d3586 100644 --- a/src/flow/src/lib.rs +++ b/src/flow/src/lib.rs @@ -38,6 +38,14 @@ mod server; mod transform; mod utils; +// Re-export the reserved checkpoint-persistence contract so internal +// producers of the sink state schema (e.g. the enterprise incremental flow +// state table) can reference the exact epoch column name and sentinel window +// timestamp without duplicating literals. The definitions themselves live in +// the private `batching_mode` module; see its docs for the sentinel safety +// caveat. +pub use batching_mode::{CHECKPOINT_SENTINEL_WINDOW_TS_MILLIS, INTERNAL_FLOW_EPOCH_COL_NAME}; + #[cfg(test)] mod test_utils;