From 40dac94dc6b9a28391da39ac0371430ecc02a0d2 Mon Sep 17 00:00:00 2001 From: discord9 Date: Tue, 24 Mar 2026 15:35:53 +0800 Subject: [PATCH] docs: explain field Signed-off-by: discord9 --- src/common/meta/src/rpc/ddl.rs | 2 ++ src/query/src/options.rs | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/src/common/meta/src/rpc/ddl.rs b/src/common/meta/src/rpc/ddl.rs index 21997c7b05..ed6f78154a 100644 --- a/src/common/meta/src/rpc/ddl.rs +++ b/src/common/meta/src/rpc/ddl.rs @@ -1432,8 +1432,10 @@ pub struct QueryContext { pub timezone: String, pub extensions: HashMap, pub channel: u8, + /// Maps region id -> snapshot upper bound sequence for that region. #[serde(default)] pub snapshot_seqs: HashMap, + /// Maps region id -> minimal SST sequence allowed for that region. #[serde(default)] pub sst_min_sequences: HashMap, } diff --git a/src/query/src/options.rs b/src/query/src/options.rs index 758db65f46..9b60b64759 100644 --- a/src/query/src/options.rs +++ b/src/query/src/options.rs @@ -60,9 +60,13 @@ pub enum FlowIncrementalMode { #[derive(Debug, Clone, PartialEq, Eq, Default)] pub struct FlowQueryExtensions { + /// Maps region id -> lower exclusive sequence bound for incremental reads. pub incremental_after_seqs: Option>, + /// Incremental read mode requested by the caller. pub incremental_mode: Option, + /// Whether the caller expects per-region watermark metadata in terminal metrics. pub return_region_seq: bool, + /// Optional sink table id used to distinguish source scans from sink reads. pub sink_table_id: Option, }