Skip to content

Commit ec18066

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

23 files changed

Lines changed: 1 addition & 92 deletions

File tree

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -92,10 +92,6 @@ impl ArrayInsert {
9292
}
9393

9494
impl PhysicalExpr for ArrayInsert {
95-
fn as_any(&self) -> &dyn Any {
96-
self
97-
}
98-
9995
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
10096
Display::fmt(self, f)
10197
}

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,6 @@ impl GetArrayStructFields {
7575
}
7676

7777
impl PhysicalExpr for GetArrayStructFields {
78-
fn as_any(&self) -> &dyn Any {
79-
self
80-
}
81-
8278
fn data_type(&self, input_schema: &Schema) -> DataFusionResult<DataType> {
8379
let struct_field = self.child_field(input_schema)?;
8480
match self.child.data_type(input_schema)? {

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -113,10 +113,6 @@ impl ListExtract {
113113
}
114114

115115
impl PhysicalExpr for ListExtract {
116-
fn as_any(&self) -> &dyn Any {
117-
self
118-
}
119-
120116
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
121117
Display::fmt(self, f)
122118
}

native/spark-expr/src/bloom_filter/bloom_filter_agg.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ pub struct BloomFilterAgg {
4141

4242
#[inline]
4343
fn extract_i32_from_literal(expr: Arc<dyn PhysicalExpr>) -> i32 {
44-
match expr.as_any().downcast_ref::<Literal>().unwrap().value() {
44+
match (*expr).downcast_ref::<Literal>().unwrap().value() {
4545
ScalarValue::Int64(scalar_value) => scalar_value.unwrap() as i32,
4646
_ => {
4747
unreachable!()

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,9 +84,6 @@ impl IfExpr {
8484

8585
impl PhysicalExpr for IfExpr {
8686
/// Return a reference to Any that can be used for down-casting
87-
fn as_any(&self) -> &dyn Any {
88-
self
89-
}
9087
9188
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
9289
Display::fmt(self, f)

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -695,10 +695,6 @@ impl Display for Cast {
695695
}
696696

697697
impl PhysicalExpr for Cast {
698-
fn as_any(&self) -> &dyn Any {
699-
self
700-
}
701-
702698
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
703699
Display::fmt(self, f)
704700
}

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -77,10 +77,6 @@ impl Display for ToCsv {
7777
}
7878

7979
impl PhysicalExpr for ToCsv {
80-
fn as_any(&self) -> &dyn Any {
81-
self
82-
}
83-
8480
fn data_type(&self, _: &Schema) -> Result<DataType> {
8581
Ok(DataType::Utf8)
8682
}

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,10 +85,6 @@ impl Display for TimestampTruncExpr {
8585
}
8686

8787
impl PhysicalExpr for TimestampTruncExpr {
88-
fn as_any(&self) -> &dyn Any {
89-
self
90-
}
91-
9288
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
9389
Display::fmt(self, f)
9490
}

native/spark-expr/src/json_funcs/from_json.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -86,10 +86,6 @@ impl PartialEq<dyn Any> for FromJson {
8686
}
8787

8888
impl PhysicalExpr for FromJson {
89-
fn as_any(&self) -> &dyn Any {
90-
self
91-
}
92-
9389
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
9490
Display::fmt(self, f)
9591
}

native/spark-expr/src/json_funcs/to_json.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -79,10 +79,6 @@ impl PartialEq<dyn Any> for ToJson {
7979
}
8080

8181
impl PhysicalExpr for ToJson {
82-
fn as_any(&self) -> &dyn Any {
83-
self
84-
}
85-
8682
fn fmt_sql(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
8783
Display::fmt(self, f)
8884
}

0 commit comments

Comments
 (0)