Skip to content

Commit 68f1a09

Browse files
committed
Fix after merging in latest datafusion main in the feature branch.
1 parent ec18066 commit 68f1a09

20 files changed

Lines changed: 3 additions & 25 deletions

File tree

native/spark-expr/src/array_funcs/array_insert.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ use datafusion::logical_expr::ColumnarValue;
3030
use datafusion::physical_expr::PhysicalExpr;
3131
use std::hash::Hash;
3232
use std::{
33-
any::Any,
3433
fmt::{Debug, Display, Formatter},
3534
sync::Arc,
3635
};

native/spark-expr/src/array_funcs/get_array_struct_fields.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ use datafusion::logical_expr::ColumnarValue;
2727
use datafusion::physical_expr::PhysicalExpr;
2828
use std::hash::Hash;
2929
use std::{
30-
any::Any,
3130
fmt::{Debug, Display, Formatter},
3231
sync::Arc,
3332
};

native/spark-expr/src/array_funcs/list_extract.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ use datafusion::logical_expr::ColumnarValue;
2626
use datafusion::physical_expr::PhysicalExpr;
2727
use std::hash::Hash;
2828
use std::{
29-
any::Any,
3029
fmt::{Debug, Display, Formatter},
3130
sync::Arc,
3231
};

native/spark-expr/src/conditional_funcs/if_expr.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ use datafusion::logical_expr::ColumnarValue;
2424
use datafusion::physical_expr::{expressions::CaseExpr, PhysicalExpr};
2525
use std::fmt::{Display, Formatter};
2626
use std::hash::Hash;
27-
use std::{any::Any, sync::Arc};
27+
use std::sync::Arc;
2828

2929
/// IfExpr is a wrapper around CaseExpr, because `IF(a, b, c)` is semantically equivalent to
3030
/// `CASE WHEN a THEN b ELSE c END`.
@@ -83,8 +83,6 @@ impl IfExpr {
8383
}
8484

8585
impl PhysicalExpr for IfExpr {
86-
/// Return a reference to Any that can be used for down-casting
87-
8886
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
8987
Display::fmt(self, f)
9088
}

native/spark-expr/src/conversion_funcs/cast.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,6 @@ use datafusion::common::{internal_err, DataFusionError, Result as DataFusionResu
6262
use datafusion::physical_expr::PhysicalExpr;
6363
use datafusion::physical_plan::ColumnarValue;
6464
use std::{
65-
any::Any,
6665
fmt::{Debug, Display, Formatter},
6766
hash::Hash,
6867
sync::Arc,

native/spark-expr/src/csv_funcs/to_csv.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ use arrow::datatypes::{DataType, Schema};
2323
use datafusion::common::Result;
2424
use datafusion::logical_expr::ColumnarValue;
2525
use datafusion::physical_expr::PhysicalExpr;
26-
use std::any::Any;
2726
use std::fmt::{Display, Formatter};
2827
use std::hash::Hash;
2928
use std::sync::Arc;

native/spark-expr/src/datetime_funcs/timestamp_trunc.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ use datafusion::logical_expr::ColumnarValue;
2323
use datafusion::physical_expr::PhysicalExpr;
2424
use std::hash::Hash;
2525
use std::{
26-
any::Any,
2726
fmt::{Debug, Display, Formatter},
2827
sync::Arc,
2928
};

native/spark-expr/src/math_funcs/internal/checkoverflow.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@ use std::hash::Hash;
2828

2929
use crate::SparkError;
3030
use std::{
31-
any::Any,
3231
fmt::{Display, Formatter},
3332
sync::Arc,
3433
};

native/spark-expr/src/math_funcs/internal/decimal_rescale_check.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ use datafusion::logical_expr::ColumnarValue;
2929
use datafusion::physical_expr::PhysicalExpr;
3030
use std::hash::Hash;
3131
use std::{
32-
any::Any,
3332
fmt::{Display, Formatter},
3433
sync::Arc,
3534
};

native/spark-expr/src/math_funcs/internal/normalize_nan.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ use datafusion::logical_expr::ColumnarValue;
2626
use datafusion::physical_expr::PhysicalExpr;
2727
use std::hash::Hash;
2828
use std::{
29-
any::Any,
3029
fmt::{Display, Formatter},
3130
sync::Arc,
3231
};

0 commit comments

Comments
 (0)