mirror of
https://github.com/lancedb/lancedb.git
synced 2026-10-29 14:56:51 +00:00
fix(mv): keep native source definitions compact
This commit is contained in:
@@ -313,7 +313,7 @@ pub fn read_staging(metadata: &HashMap<String, String>) -> Result<Option<Staging
|
||||
#[derive(Debug, Clone, PartialEq, Eq)]
|
||||
pub struct MaterializedViewDefinition {
|
||||
/// A table-bound native pair source. It is never evaluated per source row.
|
||||
pub duplicate_pairs: Option<DuplicatePairsView>,
|
||||
pub duplicate_pairs: Option<Box<DuplicatePairsView>>,
|
||||
/// 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.
|
||||
|
||||
@@ -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)]
|
||||
|
||||
@@ -284,7 +284,7 @@ fn extract(query: &Query) -> Result<MaterializedViewDefinition> {
|
||||
&& 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(_), .. }) => {
|
||||
|
||||
Reference in New Issue
Block a user