From 400f5d12ddc6a088bc3d3f5cd603dd15102e75f9 Mon Sep 17 00:00:00 2001 From: discord9 Date: Wed, 29 Apr 2026 18:39:07 +0800 Subject: [PATCH] docs: explain should_collect_region_watermark_from_extensions Signed-off-by: discord9 --- src/query/src/options.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/query/src/options.rs b/src/query/src/options.rs index 6cb74f0305..688d6315b0 100644 --- a/src/query/src/options.rs +++ b/src/query/src/options.rs @@ -184,6 +184,10 @@ impl FlowQueryExtensions { } } +/// Returns whether raw Flow query extensions request terminal region watermark collection. +/// +/// This is only an intent/presence check for transport/scan plumbing; callers that need +/// validated Flow options must still use [`FlowQueryExtensions::parse_flow_extensions`]. pub fn should_collect_region_watermark_from_extensions( extensions: &HashMap, ) -> bool {