From 0917eb6ca6d26ce4f35b16fb93ccb4b3d89edd69 Mon Sep 17 00:00:00 2001 From: Yang Cen <159225399+BubbleCal@users.noreply.github.com> Date: Sat, 26 Sep 2026 15:56:53 +0800 Subject: [PATCH] fix(mv): keep native source definitions compact --- rust/lancedb/src/materialized_view.rs | 2 +- rust/lancedb/src/materialized_view/duplicate_pairs.rs | 2 +- rust/lancedb/src/materialized_view/query.rs | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/rust/lancedb/src/materialized_view.rs b/rust/lancedb/src/materialized_view.rs index c2185eafa..2316e8f9f 100644 --- a/rust/lancedb/src/materialized_view.rs +++ b/rust/lancedb/src/materialized_view.rs @@ -313,7 +313,7 @@ pub fn read_staging(metadata: &HashMap) -> Result, + pub duplicate_pairs: Option>, /// Name of the source table, in the same database as the view. pub source_table: String, /// Namespace path holding the source table; empty is the root namespace. diff --git a/rust/lancedb/src/materialized_view/duplicate_pairs.rs b/rust/lancedb/src/materialized_view/duplicate_pairs.rs index c22cd1086..765f01852 100644 --- a/rust/lancedb/src/materialized_view/duplicate_pairs.rs +++ b/rust/lancedb/src/materialized_view/duplicate_pairs.rs @@ -30,7 +30,7 @@ use crate::table::datafusion::udtf::duplicate_pairs::{ }; use crate::{Error, Result}; -pub(crate) const FUNCTION_NAME: &str = "vector_duplicate_pairs"; +pub(super) const FUNCTION_NAME: &str = "vector_duplicate_pairs"; /// A native table-function source, pinned for the lifetime of the view. #[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)] diff --git a/rust/lancedb/src/materialized_view/query.rs b/rust/lancedb/src/materialized_view/query.rs index 7dd407315..11bd05fda 100644 --- a/rust/lancedb/src/materialized_view/query.rs +++ b/rust/lancedb/src/materialized_view/query.rs @@ -284,7 +284,7 @@ fn extract(query: &Query) -> Result { && index_hints.is_empty() => { let (namespace, table, config) = super::duplicate_pairs::source(args)?; - duplicate_pairs = Some(config); + duplicate_pairs = Some(Box::new(config)); (namespace, table) } Some(TableFactor::Table { args: Some(_), .. }) => {