Merge pull request #17 from probably-nothing-labs/df-41

upgrade to datafusion 41.0.0

Cargo.toml

@@ -17,7 +17,7 @@ description = "Embeddable stream processing engine"
 
 [workspace.dependencies]
 df-streams-core = { path = "crates/core" }
-datafusion = "40.0"
+datafusion = "41.0.0"
 
 arrow = { version = "52.0.0", features = ["prettyprint"] }
 arrow-array = { version = "52.0.0", default-features = false, features = [
@@ -39,7 +39,12 @@ futures = "0.3"
 tracing = "0.1.40"
 tracing-log = "0.2.0"
 tracing-subscriber = "0.3.18"
-tokio = { version = "1.36", features = ["macros", "rt", "sync", "rt-multi-thread"] }
+tokio = { version = "1.36", features = [
+  "macros",
+  "rt",
+  "sync",
+  "rt-multi-thread",
+] }
 async-trait = "0.1.81"
 rdkafka = "0.36.2"
 log = "^0.4"

examples/examples/csv_streaming.rs

@@ -2,7 +2,8 @@ use datafusion::common::test_util::datafusion_test_data;
 use datafusion::dataframe::DataFrameWriteOptions;
 use datafusion::datasource::MemTable;
 use datafusion::error::Result;
-use datafusion::logical_expr::{col, max, min};
+use datafusion::functions_aggregate::expr_fn::{max, min};
+use datafusion::logical_expr::col;
 use datafusion::prelude::*;
 
 /// This example demonstrates executing a simple query against an Arrow data source (CSV) and

examples/examples/kafka_rideshare.rs

@@ -1,7 +1,8 @@
 use datafusion::error::Result;
 use datafusion::functions::core::expr_ext::FieldAccessor;
 use datafusion::functions_aggregate::count::count;
-use datafusion::logical_expr::{col, max, min};
+use datafusion::functions_aggregate::expr_fn::{max, min};
+use datafusion::logical_expr::col;
 
 use df_streams_core::context::Context;
 use df_streams_core::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};

examples/examples/simple_aggregation.rs

@@ -3,8 +3,8 @@ use std::time::Duration;
 use datafusion::error::Result;
 use datafusion::functions_aggregate::average::avg;
 use datafusion::functions_aggregate::count::count;
-use datafusion::logical_expr::lit;
-use datafusion::logical_expr::{col, max, min};
+use datafusion::functions_aggregate::expr_fn::{max, min};
+use datafusion::logical_expr::{col, lit};
 
 use df_streams_core::context::Context;
 use df_streams_core::datasource::kafka::{ConnectionOpts, KafkaTopicBuilder};