File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
datafusion/physical-expr/src/expressions Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -216,9 +216,15 @@ impl InterleaveBuilder {
216216 Ok ( ColumnarValue :: Array ( self . arrays . remove ( 0 ) ) )
217217 } else {
218218 // Otherwise make a new null array with the correct type and length
219- Ok ( ColumnarValue :: Array ( new_null_array ( self . arrays [ 0 ] . data_type ( ) , self . indices . len ( ) ) ) )
219+ Ok ( ColumnarValue :: Array ( new_null_array (
220+ self . arrays [ 0 ] . data_type ( ) ,
221+ self . indices . len ( ) ,
222+ ) ) )
220223 }
221- } else if self . arrays . len ( ) == 2 && !self . indices . iter ( ) . any ( |( array_ix, _) | * array_ix == 0 ) && self . arrays [ 1 ] . len ( ) == self . indices . len ( ) {
224+ } else if self . arrays . len ( ) == 2
225+ && !self . indices . iter ( ) . any ( |( array_ix, _) | * array_ix == 0 )
226+ && self . arrays [ 1 ] . len ( ) == self . indices . len ( )
227+ {
222228 // There's only a single non-null array and no references to the null array.
223229 // We can take a shortcut and return the non-null array directly.
224230 Ok ( ColumnarValue :: Array ( self . arrays . remove ( 1 ) ) )
You can’t perform that action at this time.
0 commit comments