feat: update to df 40 (#575)

wheretrue · Jul 15, 2024 · 2432fe9 · 2432fe9
1 parent 07c6dcc
commit 2432fe9
Show file tree

Hide file tree

Showing 28 changed files with 142 additions and 49 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -37,7 +37,7 @@ resolver = "2"
 [workspace.dependencies]
 arrow = { version = "52.1.0" }
 async-trait = "0.1.80"
-datafusion = { version = "39", features = ["compression", "parquet"] }
+datafusion = { version = "40", features = ["compression", "parquet"] }
 futures = "0.3"
 noodles = { version = "0.77" }
 object_store = { version = "0.10.1" }

diff --git a/exon/exon-cli/Cargo.toml b/exon/exon-cli/Cargo.toml
@@ -10,7 +10,7 @@ version.workspace = true
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-datafusion-cli = { version = "39" }
+datafusion-cli = { version = "40" }
 clap = { version = "4", features = ["derive", "cargo"] }
 datafusion = { workspace = true }
 exon = { path = "../exon-core", version = "0.26.1", features = ["default"] }

diff --git a/exon/exon-core/src/datasources/bam/indexed_scanner.rs b/exon/exon-core/src/datasources/bam/indexed_scanner.rs
@@ -79,6 +79,10 @@ impl ExecutionPlan for IndexedBAMScan {
         self
     }
 
+    fn name(&self) -> &str {
+        "IndexedBAMScan"
+    }
+
     fn repartitioned(
         &self,
         target_partitions: usize,

diff --git a/exon/exon-core/src/datasources/bam/scanner.rs b/exon/exon-core/src/datasources/bam/scanner.rs
@@ -93,6 +93,10 @@ impl ExecutionPlan for BAMScan {
         Ok(self.statistics.clone())
     }
 
+    fn name(&self) -> &str {
+        "BAMScan"
+    }
+
     fn repartitioned(
         &self,
         target_partitions: usize,

diff --git a/exon/exon-core/src/datasources/bcf/scanner.rs b/exon/exon-core/src/datasources/bcf/scanner.rs
@@ -91,6 +91,10 @@ impl ExecutionPlan for BCFScan {
         self
     }
 
+    fn name(&self) -> &str {
+        "BCFScanExec"
+    }
+
     fn schema(&self) -> SchemaRef {
         self.projected_schema.clone()
     }

diff --git a/exon/exon-core/src/datasources/bed/scanner.rs b/exon/exon-core/src/datasources/bed/scanner.rs
@@ -89,6 +89,10 @@ impl ExecutionPlan for BEDScan {
         self
     }
 
+    fn name(&self) -> &str {
+        "BEDScan"
+    }
+
     fn properties(&self) -> &PlanProperties {
         &self.properties
     }

diff --git a/exon/exon-core/src/datasources/bigwig/value/scanner.rs b/exon/exon-core/src/datasources/bigwig/value/scanner.rs
@@ -86,6 +86,10 @@ impl ExecutionPlan for Scanner {
         self
     }
 
+    fn name(&self) -> &str {
+        "BigWigValueScanner"
+    }
+
     fn schema(&self) -> SchemaRef {
         self.projected_schema.clone()
     }