Fixed compilation errors

Author: jared-m-combs

Cargo.toml

@@ -43,10 +43,10 @@ datafusion-physical-expr = { git = "https://github.com/polygon-io/arrow-datafusi
 datafusion-physical-plan = { git = "https://github.com/polygon-io/arrow-datafusion", rev = "1c92803" }
 datafusion-sql = { git = "https://github.com/polygon-io/arrow-datafusion", rev = "1c92803" }
 futures = "0.3"
-itertools = "0.14"
+itertools = "0.13"
 log = "0.4"
-object_store = "0.12"
-ordered-float = "5.0.0"
+object_store = "0.11"
+ordered-float = "4.6.0"
 
 [dev-dependencies]
 anyhow = "1.0.95"

src/materialized/dependencies.rs

@@ -110,14 +110,14 @@ impl TableFunctionImpl for FileDependenciesUdtf {
             "mv_dependencies: table '{table_name} is not a materialized view. (Materialized TableProviders must be registered using register_materialized"),
         ))?;
 
-        Ok(Arc::new(ViewTable::new(
+        Ok(Arc::new(ViewTable::try_new(
             mv_dependencies_plan(
                 mv,
                 self.row_metadata_registry.as_ref(),
                 &self.config_options,
             )?,
             None,
-        )))
+        )?))
     }
 }
 
@@ -224,7 +224,7 @@ impl TableFunctionImpl for StaleFilesUdtf {
                 ])?
                 .build()?;
 
-        Ok(Arc::new(ViewTable::new(logical_plan, None)))
+        Ok(Arc::new(ViewTable::try_new(logical_plan, None)?))
     }
 }
 

src/materialized/file_metadata.rs

@@ -702,7 +702,7 @@ impl FileMetadataBuilder {
             .append_value(format!("{store_url}{}", meta.location));
         self.last_modified
             .append_option(meta.last_modified.timestamp_nanos_opt());
-        self.size.append_value(meta.size); // this is not lossy assuming we're on a 64-bit platform
+        self.size.append_value(meta.size as u64); // this is not lossy assuming we're on a 64-bit platform
     }
 
     fn finish(mut self) -> Result<RecordBatch> {
@@ -763,7 +763,7 @@ impl FileMetadataProvider for DefaultFileMetadataProvider {
         let prefix = url.prefix().clone();
 
         let list = match is_dir {
-            true => store.list(Some(&prefix)),
+            true => stream::iter(store.list(Some(&prefix)).collect::<Vec<_>>().await).boxed(),
             false => futures::stream::once(async move { store.head(&prefix).await }).boxed(),
         };
 

src/rewrite/exploitation.rs

@@ -457,7 +457,6 @@ impl DisplayAs for OneOfExec {
                     )
                 )
             }
-            DisplayFormatType::TreeRender => Ok(()),
         }
     }
 }

src/rewrite/normal_form.rs

@@ -1194,7 +1194,7 @@ mod test {
             TestCase {
                 name: "naked table scan with pushed down filters",
                 base: "SELECT column1 FROM t1 WHERE column2 <= 3",
-                query: "SELECT FROM t1 WHERE column2 <= 3",
+                query: "SELECT column1 FROM t1 WHERE column2 <= 3",
             },
         ];