update

chenkovsky · chenkovsky · commit faccdabe73aa · 2025-09-20T11:09:50.000+08:00
diff --git a/datafusion/spark/src/function/array/shuffle.rs b/datafusion/spark/src/function/array/shuffle.rs
@@ -47,7 +47,7 @@ impl Default for SparkShuffle {
 impl SparkShuffle {
     pub fn new() -> Self {
         Self {
-            signature: Signature::any(1, Volatility::Volatile),
+            signature: Signature::arrays(1,  None, Volatility::Volatile),
         }
     }
 }
@@ -98,7 +98,7 @@ pub fn array_shuffle_inner(arg: &[ArrayRef]) -> Result<ArrayRef> {
     }
 }
 
-fn general_array_shuffle<O: OffsetSizeTrait + TryFrom<i64>>(
+fn general_array_shuffle<O: OffsetSizeTrait>(
     array: &GenericListArray<O>,
     field: &FieldRef,
 ) -> Result<ArrayRef> {

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ impl Default for SparkShuffle {`
`47`	`47`	`impl SparkShuffle {`
`48`	`48`	`pub fn new() -> Self {`
`49`	`49`	`Self {`
`50`		`- signature: Signature::any(1, Volatility::Volatile),`
	`50`	`+ signature: Signature::arrays(1, None, Volatility::Volatile),`
`51`	`51`	`}`
`52`	`52`	`}`
`53`	`53`	`}`
`@@ -98,7 +98,7 @@ pub fn array_shuffle_inner(arg: &[ArrayRef]) -> Result<ArrayRef> {`
`98`	`98`	`}`
`99`	`99`	`}`
`100`	`100`
`101`		`-fn general_array_shuffle<O: OffsetSizeTrait + TryFrom<i64>>(`
	`101`	`+fn general_array_shuffle<O: OffsetSizeTrait>(`
`102`	`102`	`array: &GenericListArray<O>,`
`103`	`103`	`field: &FieldRef,`
`104`	`104`	`) -> Result<ArrayRef> {`