Upgrade DataFusion to 47

Author: returnString

convergence-arrow/Cargo.toml

@@ -10,7 +10,7 @@ repository = "https://github.com/returnString/convergence"
 [dependencies]
 tokio = { version = "1" }
 async-trait = "0.1"
-datafusion = "43"
+datafusion = "47"
 convergence = { path = "../convergence", version = "0.16.0" }
 chrono = "0.4"
 

convergence-arrow/examples/datafusion.rs

@@ -2,9 +2,8 @@ use convergence::server::{self, BindOptions};
 use convergence_arrow::datafusion::DataFusionEngine;
 use convergence_arrow::metadata::Catalog;
 use datafusion::arrow::datatypes::DataType;
-use datafusion::catalog_common::memory::MemorySchemaProvider;
-use datafusion::catalog::CatalogProvider;
-use datafusion::catalog_common::MemoryCatalogProvider;
+use datafusion::catalog::memory::MemorySchemaProvider;
+use datafusion::catalog::{CatalogProvider, MemoryCatalogProvider};
 use datafusion::logical_expr::Volatility;
 use datafusion::physical_plan::ColumnarValue;
 use datafusion::prelude::*;

convergence-arrow/src/metadata.rs

@@ -3,9 +3,8 @@
 use datafusion::arrow::array::{ArrayRef, Int32Builder, StringBuilder, UInt32Builder};
 use datafusion::arrow::datatypes::{Field, Schema};
 use datafusion::arrow::record_batch::RecordBatch;
-use datafusion::catalog::CatalogProvider;
-use datafusion::catalog::SchemaProvider;
-use datafusion::catalog_common::memory::MemorySchemaProvider;
+use datafusion::catalog::memory::MemorySchemaProvider;
+use datafusion::catalog::{CatalogProvider, SchemaProvider};
 use datafusion::datasource::{MemTable, TableProvider};
 use datafusion::error::DataFusionError;
 use std::convert::TryInto;