Skip to content

Commit a42fafb

Browse files
adriangbclaude
andcommitted
Remove as_any() from ScalarUDFImpl impls and fix Cast field access
Prepare for DataFusion 54 which removes `as_any()` from `ScalarUDFImpl` and changes `Cast::data_type` to `Cast::field`. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 3751908 commit a42fafb

14 files changed

Lines changed: 2 additions & 49 deletions

.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
11
/target
22
Cargo.lock
33
.idea
4+
.history

src/json_as_text.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::{ArrayRef, StringArray, StringBuilder};
@@ -33,9 +32,6 @@ impl Default for JsonAsText {
3332
}
3433

3534
impl ScalarUDFImpl for JsonAsText {
36-
fn as_any(&self) -> &dyn Any {
37-
self
38-
}
3935

4036
fn name(&self) -> &str {
4137
self.aliases[0].as_str()

src/json_contains.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::BooleanBuilder;
@@ -33,9 +32,6 @@ impl Default for JsonContains {
3332
}
3433

3534
impl ScalarUDFImpl for JsonContains {
36-
fn as_any(&self) -> &dyn Any {
37-
self
38-
}
3935

4036
fn name(&self) -> &str {
4137
self.aliases[0].as_str()

src/json_from_scalar.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::{Array, ArrayRef, AsArray, UnionArray};
@@ -35,9 +34,6 @@ impl Default for JsonFromScalar {
3534
}
3635

3736
impl ScalarUDFImpl for JsonFromScalar {
38-
fn as_any(&self) -> &dyn Any {
39-
self
40-
}
4137

4238
fn name(&self) -> &str {
4339
self.aliases[0].as_str()

src/json_get.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::ArrayRef;
@@ -39,9 +38,6 @@ impl Default for JsonGet {
3938
}
4039

4140
impl ScalarUDFImpl for JsonGet {
42-
fn as_any(&self) -> &dyn Any {
43-
self
44-
}
4541

4642
fn name(&self) -> &str {
4743
self.aliases[0].as_str()

src/json_get_array.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::{ArrayRef, ListBuilder, StringBuilder};
@@ -33,9 +32,6 @@ impl Default for JsonGetArray {
3332
}
3433

3534
impl ScalarUDFImpl for JsonGetArray {
36-
fn as_any(&self) -> &dyn Any {
37-
self
38-
}
3935

4036
fn name(&self) -> &str {
4137
self.aliases[0].as_str()

src/json_get_bool.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21

32
use datafusion::arrow::array::BooleanArray;
43
use datafusion::arrow::datatypes::DataType;
@@ -32,9 +31,6 @@ impl Default for JsonGetBool {
3231
}
3332

3433
impl ScalarUDFImpl for JsonGetBool {
35-
fn as_any(&self) -> &dyn Any {
36-
self
37-
}
3834

3935
fn name(&self) -> &str {
4036
self.aliases[0].as_str()

src/json_get_float.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::{ArrayRef, Float64Array, Float64Builder};
@@ -33,9 +32,6 @@ impl Default for JsonGetFloat {
3332
}
3433

3534
impl ScalarUDFImpl for JsonGetFloat {
36-
fn as_any(&self) -> &dyn Any {
37-
self
38-
}
3935

4036
fn name(&self) -> &str {
4137
self.aliases[0].as_str()

src/json_get_int.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21
use std::sync::Arc;
32

43
use datafusion::arrow::array::{ArrayRef, Int64Array, Int64Builder};
@@ -33,9 +32,6 @@ impl Default for JsonGetInt {
3332
}
3433

3534
impl ScalarUDFImpl for JsonGetInt {
36-
fn as_any(&self) -> &dyn Any {
37-
self
38-
}
3935

4036
fn name(&self) -> &str {
4137
self.aliases[0].as_str()

src/json_get_json.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
use std::any::Any;
21

32
use datafusion::arrow::array::StringArray;
43
use datafusion::arrow::datatypes::DataType;
@@ -31,9 +30,6 @@ impl Default for JsonGetJson {
3130
}
3231

3332
impl ScalarUDFImpl for JsonGetJson {
34-
fn as_any(&self) -> &dyn Any {
35-
self
36-
}
3733

3834
fn name(&self) -> &str {
3935
self.aliases[0].as_str()

0 commit comments

Comments
 (0)