File tree Expand file tree Collapse file tree
vortex-array/src/arrays/list/compute Expand file tree Collapse file tree Original file line number Diff line number Diff line change 33
44use itertools:: Itertools as _;
55use vortex_buffer:: BufferMut ;
6+ use vortex_error:: VortexExpect ;
67use vortex_error:: VortexResult ;
78use vortex_error:: vortex_ensure;
89use vortex_error:: vortex_err;
@@ -105,7 +106,7 @@ fn take_with_piecewise_elements<
105106
106107 for ( & data_idx, is_valid) in indices. iter ( ) . zip_eq ( validity_mask. iter ( ) ) {
107108 if !is_valid {
108- new_offsets. push ( new_offset_value :: < OutputOffsetType > ( current_offset) ? ) ;
109+ new_offsets. push ( new_offset_value :: < OutputOffsetType > ( current_offset) ) ;
109110 element_starts. push ( 0 ) ;
110111 element_lengths. push ( 0 ) ;
111112 continue ;
@@ -117,14 +118,12 @@ fn take_with_piecewise_elements<
117118 let stop = offsets[ data_idx + 1 ] ;
118119 let start: usize = start. as_ ( ) ;
119120 let stop: usize = stop. as_ ( ) ;
120- let length = stop
121- . checked_sub ( start)
122- . ok_or_else ( || vortex_err ! ( "List offsets are not monotonic at offset {stop}" ) ) ?;
121+ let length = stop - start;
123122
124123 current_offset = current_offset
125124 . checked_add ( length)
126125 . ok_or_else ( || vortex_err ! ( "List take output elements length overflow" ) ) ?;
127- new_offsets. push ( new_offset_value :: < OutputOffsetType > ( current_offset) ? ) ;
126+ new_offsets. push ( new_offset_value :: < OutputOffsetType > ( current_offset) ) ;
128127 element_starts. push ( start as u64 ) ;
129128 element_lengths. push ( length as u64 ) ;
130129 }
You can’t perform that action at this time.
0 commit comments