File tree Expand file tree Collapse file tree 1 file changed +15
-17
lines changed
native/spark-expr/src/static_invoke/char_varchar_utils Expand file tree Collapse file tree 1 file changed +15
-17
lines changed Original file line number Diff line number Diff line change @@ -78,23 +78,21 @@ fn spark_read_side_padding2(
7878 ) ) ) ,
7979 }
8080 }
81- [ ColumnarValue :: Array ( array) , ColumnarValue :: Array ( array_int) ] => {
82- match array. data_type ( ) {
83- DataType :: Utf8 => spark_read_side_padding_internal :: < i32 > (
84- array,
85- truncate,
86- ColumnarValue :: Array ( Arc :: < dyn Array > :: clone ( array_int) ) ,
87- ) ,
88- DataType :: LargeUtf8 => spark_read_side_padding_internal :: < i64 > (
89- array,
90- truncate,
91- ColumnarValue :: Array ( Arc :: < dyn Array > :: clone ( array_int) ) ,
92- ) ,
93- other => Err ( DataFusionError :: Internal ( format ! (
94- "Unsupported data type {other:?} for function rpad/read_side_padding" ,
95- ) ) ) ,
96- }
97- }
81+ [ ColumnarValue :: Array ( array) , ColumnarValue :: Array ( array_int) ] => match array. data_type ( ) {
82+ DataType :: Utf8 => spark_read_side_padding_internal :: < i32 > (
83+ array,
84+ truncate,
85+ ColumnarValue :: Array ( Arc :: < dyn Array > :: clone ( array_int) ) ,
86+ ) ,
87+ DataType :: LargeUtf8 => spark_read_side_padding_internal :: < i64 > (
88+ array,
89+ truncate,
90+ ColumnarValue :: Array ( Arc :: < dyn Array > :: clone ( array_int) ) ,
91+ ) ,
92+ other => Err ( DataFusionError :: Internal ( format ! (
93+ "Unsupported data type {other:?} for function rpad/read_side_padding" ,
94+ ) ) ) ,
95+ } ,
9896 other => Err ( DataFusionError :: Internal ( format ! (
9997 "Unsupported arguments {other:?} for function rpad/read_side_padding" ,
10098 ) ) ) ,
You can’t perform that action at this time.
0 commit comments