Merge develop

Signed-off-by: Nicholas Gates <[email protected]>

Author: gatesn

vortex-array/src/expr/exprs/list_contains.rs

@@ -295,7 +295,7 @@ fn constant_list_scalar_contains(list: ListViewScalar, values: Vector) -> Vortex
     // the results together.
     let mut result: BoolVector = BoolVector::new(
         BitBuffer::new_unset(values.len()),
-        Mask::new(values.len(), false),
+        Mask::new(values.len(), true),
     );
     for i in 0..elements.len() {
         let element = Datum::Scalar(elements.scalar_at(i));

vortex-layout/src/layouts/flat/reader.rs

@@ -142,13 +142,13 @@ impl LayoutReader for FlatReader {
 
             log::info!("Filter Array:\n{}", array.display_tree());
             let array = optimizer.optimize_array(array)?;
-            log::info!("Optimized Filter Array:\n{}", array.display_tree());
+            log::warn!("Optimized Filter Array:\n{}", array.display_tree());
 
             // Evaluate the array into a mask.
             let array_mask = array.execute_mask(&session)?;
             let array_mask = mask.bitand(&array_mask);
 
-            log::debug!(
+            log::warn!(
                 "Flat mask evaluation {} - {} (mask = {}) => {}",
                 name,
                 expr,

vortex-vector/src/struct_/scalar.rs

@@ -6,7 +6,9 @@ use crate::ScalarOps;
 use crate::VectorMut;
 use crate::VectorOps;
 use crate::struct_::StructVector;
+use crate::struct_::StructVectorMut;
 use vortex_mask::Mask;
+use vortex_mask::MaskMut;
 
 /// Represents a struct scalar value.
 ///
@@ -47,8 +49,15 @@ impl ScalarOps for StructScalar {
         }
     }
 
-    fn repeat(&self, _n: usize) -> VectorMut {
-        todo!()
+    fn repeat(&self, n: usize) -> VectorMut {
+        let fields = self
+            .0
+            .fields()
+            .iter()
+            .map(|f| f.scalar_at(0).repeat(n))
+            .collect();
+        let validity = MaskMut::new(n, self.is_valid());
+        VectorMut::Struct(StructVectorMut::new(fields, validity))
     }
 }
 

vortex-vector/src/struct_/vector.rs

@@ -149,8 +149,21 @@ impl VectorOps for StructVector {
         StructScalar::new(self.slice(index..index + 1))
     }
 
-    fn slice(&self, _range: impl RangeBounds<usize> + Clone + Debug) -> Self {
-        todo!()
+    fn slice(&self, range: impl RangeBounds<usize> + Clone + Debug) -> Self {
+        let sliced_fields: Box<[_]> = self
+            .fields
+            .iter()
+            .map(|field| field.slice(range.clone()))
+            .collect();
+
+        let sliced_validity = self.validity.slice(range);
+        let len = sliced_validity.len();
+
+        StructVector {
+            fields: Arc::new(sliced_fields),
+            validity: sliced_validity,
+            len,
+        }
     }
 
     fn clear(&mut self) {