diff --git a/rust/lance/src/io/exec/scalar_index.rs b/rust/lance/src/io/exec/scalar_index.rs index 53fcc329b3..c78ce382c0 100644 --- a/rust/lance/src/io/exec/scalar_index.rs +++ b/rust/lance/src/io/exec/scalar_index.rs @@ -584,68 +584,3 @@ impl ExecutionPlan for MaterializeIndexExec { &self.properties } } - -// #[derive(Debug)] -// pub struct FtsExec { -// dataset: Arc, -// index: Arc, -// query: ScalarQuery, -// properties: PlanProperties, -// } - -// impl DisplayAs for FtsExec { -// fn fmt_as(&self, t: DisplayFormatType, f: &mut std::fmt::Formatter) -> std::fmt::Result { -// match t { -// DisplayFormatType::Default | DisplayFormatType::Verbose => { -// write!(f, "Fts: query={:?}", self.query) -// } -// } -// } -// } - -// impl ExecutionPlan for FtsExec { -// fn as_any(&self) -> &dyn std::any::Any { -// self -// } - -// fn schema(&self) -> SchemaRef { -// SCALAR_INDEX_SCHEMA.clone() -// } - -// fn children(&self) -> Vec> { -// vec![] -// } - -// fn with_new_children( -// self: Arc, -// _children: Vec>, -// ) -> datafusion::error::Result> { -// todo!() -// } - -// fn execute( -// &self, -// _partition: usize, -// _context: Arc, -// ) -> datafusion::error::Result { -// self.index.search(query).map(|row_ids| { - -// }) -// let stream = futures::stream::iter(vec![batch_fut]) -// .then(|batch_fut| batch_fut.map_err(|err| err.into())) -// .boxed() -// as BoxStream<'static, datafusion::common::Result>; -// Ok(Box::pin(RecordBatchStreamAdapter::new( -// SCALAR_INDEX_SCHEMA.clone(), -// stream, -// ))) -// } - -// fn statistics(&self) -> datafusion::error::Result { -// Ok(Statistics::new_unknown(&SCALAR_INDEX_SCHEMA)) -// } - -// fn properties(&self) -> &PlanProperties { -// &self.properties -// } -// }