File tree Expand file tree Collapse file tree 1 file changed +2
-6
lines changed
native/spark-expr/src/conversion_funcs Expand file tree Collapse file tree 1 file changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -1041,7 +1041,7 @@ fn cast_array(
10411041 }
10421042 ( Binary , Utf8 ) => Ok ( cast_binary_to_string :: < i32 > ( & array, cast_options) ?) ,
10431043 _ if cast_options. is_adapting_schema
1044- || is_datafusion_spark_compatible ( from_type, to_type, cast_options . allow_incompat ) =>
1044+ || is_datafusion_spark_compatible ( from_type, to_type) =>
10451045 {
10461046 // use DataFusion cast only when we know that it is compatible with Spark
10471047 Ok ( cast_with_options ( & array, to_type, & native_cast_options) ?)
@@ -1208,11 +1208,7 @@ fn cast_binary_formatter(value: &[u8]) -> String {
12081208
12091209/// Determines if DataFusion supports the given cast in a way that is
12101210/// compatible with Spark
1211- fn is_datafusion_spark_compatible (
1212- from_type : & DataType ,
1213- to_type : & DataType ,
1214- allow_incompat : bool ,
1215- ) -> bool {
1211+ fn is_datafusion_spark_compatible ( from_type : & DataType , to_type : & DataType ) -> bool {
12161212 if from_type == to_type {
12171213 return true ;
12181214 }
You can’t perform that action at this time.
0 commit comments