fix some deprecation / unused import warnings (#56)

Author: davidhewitt

benches/main.rs

@@ -1,7 +1,7 @@
 use codspeed_criterion_compat::{criterion_group, criterion_main, Bencher, Criterion};
 
-use datafusion_common::ScalarValue;
-use datafusion_expr::ColumnarValue;
+use datafusion::common::ScalarValue;
+use datafusion::logical_expr::ColumnarValue;
 use datafusion_functions_json::udfs::{json_contains_udf, json_get_str_udf};
 
 fn bench_json_contains(b: &mut Bencher) {
@@ -14,7 +14,7 @@ fn bench_json_contains(b: &mut Bencher) {
         ColumnarValue::Scalar(ScalarValue::Utf8(Some("aa".to_string()))),
     ];
 
-    b.iter(|| json_contains.invoke(args).unwrap());
+    b.iter(|| json_contains.invoke_batch(args, 1).unwrap());
 }
 
 fn bench_json_get_str(b: &mut Bencher) {
@@ -27,7 +27,7 @@ fn bench_json_get_str(b: &mut Bencher) {
         ColumnarValue::Scalar(ScalarValue::Utf8(Some("aa".to_string()))),
     ];
 
-    b.iter(|| json_get_str.invoke(args).unwrap());
+    b.iter(|| json_get_str.invoke_batch(args, 1).unwrap());
 }
 
 fn criterion_benchmark(c: &mut Criterion) {

src/common.rs

@@ -176,9 +176,6 @@ fn zip_apply<'a, P: Iterator<Item = Option<JsonPath<'a>>>, C: FromIterator<Optio
     object_lookup: bool,
     return_dict: bool,
 ) -> DataFusionResult<ArrayRef> {
-    // arrow_schema "use" is workaround for https://github.com/apache/arrow-rs/issues/6400#issue-2528388332
-    use datafusion::arrow::datatypes as arrow_schema;
-
     let c = downcast_dictionary_array!(
         json_array => {
             let values = zip_apply(json_array.values(), path_array, to_array, jiter_find, object_lookup, false)?;
@@ -245,9 +242,6 @@ fn scalar_apply<C: FromIterator<Option<I>>, I>(
     jiter_find: impl Fn(Option<&str>, &[JsonPath]) -> Result<I, GetError>,
     return_dict: bool,
 ) -> DataFusionResult<ArrayRef> {
-    // arrow_schema "use" is workaround for https://github.com/apache/arrow-rs/issues/6400#issue-2528388332
-    use datafusion::arrow::datatypes as arrow_schema;
-
     let c = downcast_dictionary_array!(
         json_array => {
             let values = scalar_apply(json_array.values(), path, to_array, jiter_find, false)?;

tests/main.rs

@@ -500,7 +500,7 @@ fn test_json_get_utf8() {
         ColumnarValue::Scalar(ScalarValue::Utf8(Some("aa".to_string()))),
     ];
 
-    let ColumnarValue::Scalar(sv) = json_get_str.invoke(args).unwrap() else {
+    let ColumnarValue::Scalar(sv) = json_get_str.invoke_batch(args, 1).unwrap() else {
         panic!("expected scalar")
     };
 
@@ -518,7 +518,7 @@ fn test_json_get_large_utf8() {
         ColumnarValue::Scalar(ScalarValue::LargeUtf8(Some("aa".to_string()))),
     ];
 
-    let ColumnarValue::Scalar(sv) = json_get_str.invoke(args).unwrap() else {
+    let ColumnarValue::Scalar(sv) = json_get_str.invoke_batch(args, 1).unwrap() else {
         panic!("expected scalar")
     };