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(_), .. }) => {