fmt

vortex-serde/src/layout/reader/batch.rs

@@ -1,8 +1,8 @@
 use std::mem;
 use std::sync::Arc;
 
-use vortex::{Array, IntoArray};
 use vortex::array::StructArray;
+use vortex::{Array, IntoArray};
 use vortex_error::VortexResult;
 
 use crate::layout::{Layout, ReadResult};

vortex-serde/src/layout/reader/buffered.rs

@@ -1,6 +1,6 @@
 use std::collections::VecDeque;
 
-use vortex::array::chunked::ChunkedArray;
+use vortex::array::ChunkedArray;
 use vortex::compute::slice;
 use vortex::{Array, ArrayDType, IntoArray};
 use vortex_error::VortexResult;

vortex-serde/src/layout/reader/mod.rs

@@ -1,30 +1,29 @@
 use std::mem;
 use std::pin::Pin;
 use std::sync::{Arc, RwLock};
-use std::task::{Context, Poll, ready};
+use std::task::{ready, Context, Poll};
 
 use bytes::{Bytes, BytesMut};
 use futures::{FutureExt, Stream};
-use futures_util::{stream, StreamExt, TryStreamExt};
 use futures_util::future::BoxFuture;
-
+use futures_util::{stream, StreamExt, TryStreamExt};
 use projections::Projection;
 use schema::Schema;
-use vortex::{Array, ArrayDType, IntoArray, IntoArrayVariant};
 use vortex::array::StructArray;
-use vortex::compute::{filter, filter_indices, search_sorted, SearchSortedSide, slice, take};
 use vortex::compute::unary::subtract_scalar;
-use vortex_dtype::{DType, match_each_integer_ptype};
+use vortex::compute::{filter, filter_indices, search_sorted, slice, take, SearchSortedSide};
+use vortex::{Array, ArrayDType, IntoArray, IntoArrayVariant};
+use vortex_dtype::{match_each_integer_ptype, DType};
 use vortex_error::{vortex_bail, VortexError, VortexResult};
 use vortex_scalar::Scalar;
 
 use crate::io::VortexReadAt;
-use crate::layout::{
-    Layout, LayoutReader, MessageId, MessagesCache, ReadResult, RelativeMessageCache, Scan,
-};
 use crate::layout::footer::Footer;
 use crate::layout::reader::filtering::RowFilter;
 use crate::layout::writer::layout_writer::MAGIC_BYTES;
+use crate::layout::{
+    Layout, LayoutReader, MessageId, MessagesCache, ReadResult, RelativeMessageCache, Scan,
+};
 
 pub mod batch;
 pub mod buffered;

vortex-serde/src/layout/tests.rs

@@ -1,15 +1,14 @@
 use std::sync::Arc;
 
 use futures::StreamExt;
-
-use vortex::{ArrayDType, Context, IntoArray, IntoArrayVariant};
 use vortex::array::{ChunkedArray, PrimitiveArray, StructArray, VarBinArray};
+use vortex::{ArrayDType, Context, IntoArray, IntoArrayVariant};
 use vortex_dtype::PType;
 
-use crate::layout::{LayoutContext, LayoutReader};
 use crate::layout::reader::projections::Projection;
 use crate::layout::reader::VortexLayoutReaderBuilder;
 use crate::layout::writer::layout_writer::LayoutWriter;
+use crate::layout::{LayoutContext, LayoutReader};
 
 #[tokio::test]
 #[cfg_attr(miri, ignore)]

vortex-serde/src/layout/writer/layout_writer.rs

@@ -4,8 +4,6 @@ use std::mem;
 use flatbuffers::{FlatBufferBuilder, WIPOffset};
 use futures::{Stream, TryStreamExt};
 use itertools::Itertools;
-
-use vortex::{Array, ArrayDType, IntoArray};
 use vortex::array::{ChunkedArray, StructArray};
 use vortex::stream::ArrayStream;
 use vortex::validity::Validity;
@@ -266,15 +264,7 @@ impl<W: VortexWrite> LayoutWriter<W> {
 #[cfg(test)]
 mod tests {
     use futures_executor::block_on;
-<<<<<<< HEAD
-
     use vortex::array::{PrimitiveArray, StructArray, VarBinArray};
-    use vortex::IntoArray;
-=======
-    use vortex::array::primitive::PrimitiveArray;
-    use vortex::array::struct_::StructArray;
-    use vortex::array::varbin::VarBinArray;
->>>>>>> a97576cb (more)
     use vortex::validity::Validity;
     use vortex::IntoArray;