update datafusion to 43

roapi · Jan 1, 2025 · da158f0 · da158f0
1 parent 85dfe3a
commit da158f0
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/convergence-arrow/Cargo.toml b/convergence-arrow/Cargo.toml
@@ -10,7 +10,7 @@ repository = "https://github.com/returnString/convergence"
 [dependencies]
 tokio = { version = "1" }
 async-trait = "0.1"
-datafusion = "38"
+datafusion = "43"
 convergence = { path = "../convergence", version = "0.16.0" }
 chrono = "0.4"
 

diff --git a/convergence-arrow/src/metadata.rs b/convergence-arrow/src/metadata.rs
@@ -3,8 +3,9 @@
 use datafusion::arrow::array::{ArrayRef, Int32Builder, StringBuilder, UInt32Builder};
 use datafusion::arrow::datatypes::{Field, Schema};
 use datafusion::arrow::record_batch::RecordBatch;
-use datafusion::catalog::schema::{MemorySchemaProvider, SchemaProvider};
 use datafusion::catalog::CatalogProvider;
+use datafusion::catalog::SchemaProvider;
+use datafusion::catalog_common::memory::MemorySchemaProvider;
 use datafusion::datasource::{MemTable, TableProvider};
 use datafusion::error::DataFusionError;
 use std::convert::TryInto;
@@ -153,6 +154,7 @@ impl MetadataBuilder {
 }
 
 /// Wrapper catalog supporting generation of pg metadata (e.g. pg_catalog schema).
+#[derive(Debug)]
 pub struct Catalog {
 	wrapped: Arc<dyn CatalogProvider>,
 }

diff --git a/convergence/src/protocol_ext.rs b/convergence/src/protocol_ext.rs
@@ -138,7 +138,7 @@ impl<'a> DataRowWriter<'a> {
 	primitive_write!(write_float8, f64);
 }
 
-impl<'a> Drop for DataRowWriter<'a> {
+impl Drop for DataRowWriter<'_> {
 	fn drop(&mut self) {
 		assert_eq!(
 			self.parent.num_cols, self.current_col,