Fix incorrect import introduced during rebase

lancedb · westonpace · Oct 15, 2024 · Oct 4, 2024 · Oct 5, 2024 · Oct 14, 2024
commit 0e965ae5d38e2077925deda02cbd980c06eaf8ca
diff --git a/rust/lance-encoding/src/encoder.rs b/rust/lance-encoding/src/encoder.rs
@@ -18,7 +18,7 @@ use snafu::{location, Location};
 use crate::buffer::LanceBuffer;
 use crate::data::{DataBlock, FixedWidthDataBlock, VariableWidthBlock};
 use crate::decoder::PageEncoding;
-use crate::encodings::logical::blob::{BlobFieldEncoder, DESC_FIELD};
+use crate::encodings::logical::blob::BlobFieldEncoder;
 use crate::encodings::logical::primitive::PrimitiveStructuralEncoder;
 use crate::encodings::logical::r#struct::StructFieldEncoder;
 use crate::encodings::logical::r#struct::StructStructuralEncoder;

diff --git a/rust/lance-io/src/object_store.rs b/rust/lance-io/src/object_store.rs
    pub fn remove_stream<'a>(
        &'a self,
        locations: BoxStream<'a, Result<Path>>,
    ) -> BoxStream<Result<Path>> {
        self.inner
            .delete_stream(locations.err_into::<ObjectStoreError>().boxed())
            .err_into::<Error>()
diff --git a/rust/lance-file/src/writer/statistics.rs b/rust/lance-file/src/writer/statistics.rs

 fn cast_dictionary_arrays<'a, T: ArrowDictionaryKeyType + 'static>(
    arrays: &'a [&'a ArrayRef],
 ) -> Vec<&Arc<dyn Array>> {
    arrays
        .iter()
        .map(|x| x.as_dictionary::<T>().values())
diff --git a/rust/lance-index/src/scalar/label_list.rs b/rust/lance-index/src/scalar/label_list.rs
    fn search_values<'a>(
        &'a self,
        values: &'a Vec<ScalarValue>,
    ) -> BoxStream<Result<RowIdTreeMap>> {
        futures::stream::iter(values)
            .then(move |value| {
                let value_query = SargableQuery::Equals(value.clone());
	pub fn remove_stream<'a>(
	&'a self,
	locations: BoxStream<'a, Result<Path>>,
	) -> BoxStream<Result<Path>> {
Check warning on line 638 in rust/lance-io/src/object_store.rs GitHub Actions / linux-build (nightly) `elided lifetime has a name`
	self.inner
	.delete_stream(locations.err_into::<ObjectStoreError>().boxed())
	.err_into::<Error>()

	fn cast_dictionary_arrays<'a, T: ArrowDictionaryKeyType + 'static>(
	arrays: &'a [&'a ArrayRef],
	) -> Vec<&Arc<dyn Array>> {
Check warning on line 489 in rust/lance-file/src/writer/statistics.rs GitHub Actions / linux-build (nightly) `elided lifetime has a name`
	arrays
	.iter()
	.map(\|x\| x.as_dictionary::<T>().values())
	fn search_values<'a>(
	&'a self,
	values: &'a Vec<ScalarValue>,
	) -> BoxStream<Result<RowIdTreeMap>> {
Check warning on line 81 in rust/lance-index/src/scalar/label_list.rs GitHub Actions / linux-build (nightly) `elided lifetime has a name`
	futures::stream::iter(values)
	.then(move \|value\| {
	let value_query = SargableQuery::Equals(value.clone());