feat(flow): expose checkpoint persistence constants

Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
This commit is contained in:
discord9
2026-08-14 09:32:10 +08:00
parent d6ff1c9525
commit 1f7fb5fb8b
+8
View File
@@ -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;