Point DataFusion to version 28

sfu-db · Jul 27, 2023 · 7d8820e · 7d8820e
1 parent a84fd31
commit 7d8820e
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 10 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/connectorx/Cargo.toml b/connectorx/Cargo.toml
@@ -56,7 +56,7 @@ tokio-util = {version = "0.6", optional = true}
 urlencoding = {version = "2.1", optional = true}
 uuid = {version = "0.8", optional = true}
 j4rs = {version = "0.13", optional = true}
-datafusion = {git = "https://github.com/apache/arrow-datafusion", rev = "51b4392577554becf637a8adcefa0e7fdc79e41f", optional = true}
+datafusion = {version = "28", optional = true}
 
 [lib]
 crate-type = ["cdylib", "rlib"]

diff --git a/connectorx/examples/federated_test.rs b/connectorx/examples/federated_test.rs
@@ -201,9 +201,10 @@ fn main() {
     // println!("==== run sql 2 ====");
 
     let df = rt.block_on(ctx.sql(local_sql.as_str())).unwrap();
-    rt.block_on(df.explain(false, false).unwrap().show())
+    rt.block_on(df.clone().explain(false, false).unwrap().show())
+        .unwrap();
+    rt.block_on(df.clone().limit(5, None).unwrap().show())
         .unwrap();
-    rt.block_on(df.limit(5, None).unwrap().show()).unwrap();
     let num_rows = rt
         .block_on(df.collect())
         .unwrap()