Skip to content

Commit e06998a

Browse files
committed
Update sqlparser and datafusion
1 parent e6e5713 commit e06998a

4 files changed

Lines changed: 5 additions & 3 deletions

File tree

convergence-arrow/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ repository = "https://github.com/returnString/convergence"
1010
[dependencies]
1111
tokio = { version = "1" }
1212
async-trait = "0.1"
13-
datafusion = "31"
13+
datafusion = "34"
1414
convergence = { path = "../convergence", version = "0.14.0" }
1515
chrono = "0.4"
1616

convergence-arrow/examples/datafusion.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ use datafusion::scalar::ScalarValue;
1111
use std::sync::Arc;
1212

1313
async fn new_engine() -> DataFusionEngine {
14-
let ctx = SessionContext::with_config(
14+
let ctx = SessionContext::new_with_config(
1515
SessionConfig::new()
1616
.with_information_schema(true)
1717
.with_create_default_catalog_and_schema(false),

convergence-arrow/src/datafusion.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,8 @@ fn dummy_query() -> Statement {
4141
fetch: None,
4242
offset: None,
4343
order_by: vec![],
44+
for_clause: None,
45+
limit_by: vec![],
4446
}))
4547
}
4648

convergence/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ tokio-util = { version = "0.7", features = [ "codec" ] }
1313
thiserror = "1"
1414
bytes = "1"
1515
futures = "0.3"
16-
sqlparser = "0.38"
16+
sqlparser = "0.41"
1717
async-trait = "0.1"
1818
chrono = "0.4"
1919

0 commit comments

Comments
 (0)