merge

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

Author: gatesn

vortex-datafusion/src/persistent/opener.rs

@@ -415,7 +415,7 @@ mod tests {
 
     use super::*;
 
-    static SESSION: LazyLock<VortexSession> = LazyLock::new(|| VortexSession::default());
+    static SESSION: LazyLock<VortexSession> = LazyLock::new(VortexSession::default);
 
     #[rstest]
     #[case(0..100, 100, 100, 0..100)]

vortex-file/src/writer.rs

@@ -56,6 +56,17 @@ pub trait WriteOptionsSessionExt: SessionExt {
 impl<S: SessionExt> WriteOptionsSessionExt for S {}
 
 impl VortexWriteOptions {
+    /// Create a new [`VortexWriteOptions`] with the given session.
+    pub fn new(session: VortexSession) -> Self {
+        VortexWriteOptions {
+            session,
+            strategy: WriteStrategyBuilder::new().build(),
+            exclude_dtype: false,
+            file_statistics: PRUNING_STATS.to_vec(),
+            max_variable_length_statistics_size: 64,
+        }
+    }
+
     /// Replace the default layout strategy with the provided one.
     pub fn with_strategy(mut self, strategy: Arc<dyn LayoutStrategy>) -> Self {
         self.strategy = strategy;

vortex-scan/src/gpu/gpuscan.rs

@@ -35,7 +35,7 @@ impl GpuScan<ArrayRef> {
     ) -> VortexResult<impl ArrayIterator + 'static> {
         let dtype = self.dtype.clone();
         let stream = self.execute_stream()?;
-        let iter = runtime.block_on_stream(move |_h| stream);
+        let iter = runtime.block_on_stream(stream);
         Ok(ArrayIteratorAdapter::new(dtype, iter))
     }