diff --git a/Cargo.toml b/Cargo.toml index 9b201a6..1464f4f 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -34,7 +34,7 @@ all-features = true [dependencies] async-trait = { version = "0.1.77" } bytes = "1.4" -datafusion = "53.1.0" +datafusion = "54.0.0" futures = { version = "0.3", default-features = false, features = ["std"] } futures-util = { version = "0.3" } object_store = { version = "0.13" } diff --git a/src/file_format.rs b/src/file_format.rs index 8ecaecf..e60fc28 100644 --- a/src/file_format.rs +++ b/src/file_format.rs @@ -15,7 +15,6 @@ // specific language governing permissions and limitations // under the License. -use std::any::Any; use std::collections::HashMap; use std::fmt::Debug; use std::sync::Arc; @@ -58,10 +57,6 @@ pub struct OrcFormat; #[async_trait] impl FileFormat for OrcFormat { - fn as_any(&self) -> &dyn Any { - self - } - fn get_ext(&self) -> String { "orc".to_string() } diff --git a/src/file_source.rs b/src/file_source.rs index 023a1e8..f546058 100644 --- a/src/file_source.rs +++ b/src/file_source.rs @@ -22,7 +22,6 @@ use datafusion::datasource::table_schema::TableSchema; use datafusion::physical_plan::metrics::ExecutionPlanMetricsSet; use datafusion::physical_plan::projection::ProjectionExprs; use object_store::ObjectStore; -use std::any::Any; use std::sync::Arc; #[derive(Debug, Clone)] @@ -65,10 +64,6 @@ impl FileSource for OrcSource { .map(|f| Arc::new(f) as Arc) } - fn as_any(&self) -> &dyn Any { - self - } - fn table_schema(&self) -> &TableSchema { &self.table_schema }