Skip to content

Commit 98f2b51

Browse files
committed
Upgrade DF52
1 parent 0d1aefa commit 98f2b51

3 files changed

Lines changed: 15 additions & 15 deletions

File tree

Cargo.toml

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -29,23 +29,23 @@ rust-version = "1.85.1"
2929

3030
[dependencies]
3131
aquamarine = "0.6.0"
32-
arrow = "57.0.0"
33-
arrow-schema = "57.0.0"
32+
arrow = "57.1.0"
33+
arrow-schema = "57.1.0"
3434
async-trait = "0.1.89"
3535
dashmap = "6"
36-
datafusion = "51"
37-
datafusion-common = "51"
38-
datafusion-expr = "51"
39-
datafusion-functions = "51"
40-
datafusion-functions-aggregate = "51"
41-
datafusion-optimizer = "51"
42-
datafusion-physical-expr = "51"
43-
datafusion-physical-plan = "51"
44-
datafusion-sql = "51"
36+
datafusion = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
37+
datafusion-common = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
38+
datafusion-expr = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
39+
datafusion-functions = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
40+
datafusion-functions-aggregate = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
41+
datafusion-optimizer = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
42+
datafusion-physical-expr = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
43+
datafusion-physical-plan = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
44+
datafusion-sql = { git = "https://github.com/apache/datafusion", rev = "aee5cd9" }
4545
futures = "0.3"
4646
itertools = "0.14"
4747
log = "0.4"
48-
object_store = "0.12"
48+
object_store = "0.12.4"
4949
ordered-float = "5.0.0"
5050

5151
[dev-dependencies]

src/materialized/dependencies.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -860,7 +860,7 @@ fn project_dfschema(schema: &DFSchema, indices: &HashSet<usize>) -> Result<DFSch
860860
.filter_map(|i| {
861861
indices.contains(&i).then_some({
862862
let (reference, field) = schema.qualified_field(i);
863-
(reference.cloned(), Arc::new(field.clone()))
863+
(reference.cloned(), field.clone())
864864
})
865865
})
866866
.collect_vec();

src/rewrite/normal_form.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -718,11 +718,11 @@ impl Predicate {
718718
Some(range) => range,
719719
};
720720

721-
if other_range.contains(range)? != Interval::CERTAINLY_TRUE {
721+
if other_range.contains(range)? != Interval::TRUE {
722722
return Ok(None);
723723
}
724724

725-
if range.contains(other_range)? != Interval::CERTAINLY_TRUE {
725+
if range.contains(other_range)? != Interval::TRUE {
726726
if !(range.lower().is_null() || range.upper().is_null())
727727
&& (range.lower().eq(range.upper()))
728728
{

0 commit comments

Comments
 (0)