Pin deps to DataFusion 52.2 / Arrow 58.0

Cargo.toml

@@ -26,3 +26,59 @@ indicatif = "0.18"
 env_logger = "0.11"
 insta = "1.43.2"
 rustyline = { version = "14.0", features = ["derive"] }
+
+[patch.crates-io]
+# pydantic forks
+arrow = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-arith = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-array = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-buffer = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-cast = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-csv = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-data = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-ipc = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-json = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-ord = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-row = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-schema = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-select = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+arrow-string = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet-variant = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet-variant-compute = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+parquet-variant-json = { git = "https://github.com/pydantic/arrow-rs.git", branch = "main" }
+datafusion = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-catalog = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-catalog-listing = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-common-runtime = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-arrow = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-avro = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-csv = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-json = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-datasource-parquet = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-doc = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-execution = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-expr = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-expr-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-aggregate = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-aggregate-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-nested = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-table = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-window = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-functions-window-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-macros = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-optimizer = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-expr = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-expr-adapter = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-expr-common = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-optimizer = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-physical-plan = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-pruning = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-session = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-spark = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-sql = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-sqllogictest = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }
+datafusion-substrait = { git = "https://github.com/pydantic/datafusion.git", branch = "pydantic-main" }

src/cast_to_variant.rs

@@ -157,9 +157,6 @@ impl CastToVariantUdf {
 }
 
 impl ScalarUDFImpl for CastToVariantUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "cast_to_variant"

src/impl_variant_get.rs

@@ -23,9 +23,6 @@ macro_rules! impl_variant_get_typed {
         }
 
         impl ScalarUDFImpl for $struct_name {
-            fn as_any(&self) -> &dyn std::any::Any {
-                self
-            }
 
             fn name(&self) -> &str {
                 $func_name

src/is_variant_null.rs

@@ -27,9 +27,6 @@ impl Default for IsVariantNullUdf {
 }
 
 impl ScalarUDFImpl for IsVariantNullUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "is_variant_null"

src/json_to_variant.rs

@@ -38,9 +38,6 @@ impl Default for JsonToVariantUdf {
 }
 
 impl ScalarUDFImpl for JsonToVariantUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "json_to_variant"

src/variant_get.rs

@@ -335,9 +335,6 @@ impl Default for VariantGetUdf {
 }
 
 impl ScalarUDFImpl for VariantGetUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_get"
@@ -392,9 +389,6 @@ impl Default for VariantGetFieldUdf {
 }
 
 impl ScalarUDFImpl for VariantGetFieldUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_get_field"

src/variant_list_construct.rs

@@ -28,9 +28,6 @@ impl Default for VariantListConstruct {
 }
 
 impl ScalarUDFImpl for VariantListConstruct {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_list_construct"

src/variant_list_delete.rs

@@ -67,9 +67,6 @@ fn delete_list_element(variant_list: Variant, index: usize) -> Result<(Vec<u8>,
 }
 
 impl ScalarUDFImpl for VariantListDelete {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_list_delete"

src/variant_list_insert.rs

@@ -29,9 +29,6 @@ impl Default for VariantListInsert {
 }
 
 impl ScalarUDFImpl for VariantListInsert {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_list_insert"

src/variant_normalize.rs

@@ -62,9 +62,6 @@ impl Default for VariantNormalizeUdf {
 }
 
 impl ScalarUDFImpl for VariantNormalizeUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_normalize"

src/variant_object_construct.rs

@@ -29,9 +29,6 @@ impl Default for VariantObjectConstruct {
 }
 
 impl ScalarUDFImpl for VariantObjectConstruct {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_construct"

src/variant_object_delete.rs

@@ -29,9 +29,6 @@ impl Default for VariantObjectDelete {
 }
 
 impl ScalarUDFImpl for VariantObjectDelete {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_delete"

src/variant_object_insert.rs

@@ -29,9 +29,6 @@ impl Default for VariantObjectInsert {
 }
 
 impl ScalarUDFImpl for VariantObjectInsert {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_insert"

src/variant_object_keys.rs

@@ -45,9 +45,6 @@ fn append_keys_from_variant(v_opt: Option<Variant>, builder: &mut ListBuilder<St
 }
 
 impl ScalarUDFImpl for VariantObjectKeys {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_object_keys"

src/variant_pretty.rs

@@ -28,9 +28,6 @@ impl Default for VariantPretty {
 }
 
 impl ScalarUDFImpl for VariantPretty {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_pretty"

src/variant_to_json.rs

@@ -39,9 +39,6 @@ impl Default for VariantToJsonUdf {
 }
 
 impl ScalarUDFImpl for VariantToJsonUdf {
-    fn as_any(&self) -> &dyn std::any::Any {
-        self
-    }
 
     fn name(&self) -> &str {
         "variant_to_json"