refactor: show LastRow merge mode directly in diagnostics

Signed-off-by: discord9 <55937128+discord9@users.noreply.github.com>
This commit is contained in:
discord9
2026-09-09 17:25:39 +08:00
parent 9a3f4c45f0
commit 1d8bcd5248
+7 -12
View File
@@ -82,7 +82,7 @@ pub trait VectorIndexEngine: Send + Sync {
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Display)]
pub enum TimeSeriesRowSelector {
/// Only keep the last row of each time-series.
#[strum(to_string = "LastRow")]
#[strum(to_string = "LastRow {{ after_merge: {after_merge} }}")]
LastRow {
/// Whether selection runs after cross-source merge and deduplication.
after_merge: bool,
@@ -209,16 +209,6 @@ impl Display for ScanRequest {
series_row_selector
)?;
}
if matches!(
self.series_row_selector,
Some(TimeSeriesRowSelector::LastRow { after_merge: true })
) {
write!(
f,
"{}series_row_selector_after_merge: true",
delimiter.as_str()
)?;
}
if let Some(sequence) = &self.memtable_max_sequence {
write!(f, "{}sequence: {}", delimiter.as_str(), sequence)?;
}
@@ -344,7 +334,12 @@ mod tests {
};
assert_eq!(
request.to_string(),
"ScanRequest { series_row_selector: LastRow, series_row_selector_after_merge: true, snapshot_on_scan: true, exact_sequence_range: true }"
"ScanRequest { series_row_selector: LastRow { after_merge: true }, snapshot_on_scan: true, exact_sequence_range: true }"
);
assert_eq!(
TimeSeriesRowSelector::LastRow { after_merge: false }.to_string(),
"LastRow { after_merge: false }"
);
let request = ScanRequest {