File tree Expand file tree Collapse file tree 1 file changed +2
-19
lines changed
src/query/expression/src/aggregate Expand file tree Collapse file tree 1 file changed +2
-19
lines changed Original file line number Diff line number Diff line change @@ -267,25 +267,8 @@ impl<'a> TableAdapter for AdapterImpl<'a> {
267267 & mut self ,
268268 state : & mut ProbeState ,
269269 need_compare_count : usize ,
270- mut no_match_count : usize ,
270+ no_match_count : usize ,
271271 ) -> usize {
272- let mut count = 0 ;
273- for i in 0 ..need_compare_count {
274- let item = & state. group_compare_vector [ i] ;
275- if state. group_hashes [ item. row ] == item. row_ptr . hash ( & self . payload . row_layout ) {
276- if i != count {
277- state. group_compare_vector [ count] = item. clone ( ) ;
278- }
279- count += 1 ;
280- } else {
281- state. no_match_vector [ no_match_count] = item. clone ( ) ;
282- no_match_count += 1 ;
283- }
284- }
285- if count == 0 {
286- return no_match_count;
287- }
288-
289272 CompareState {
290273 compare : & mut state. group_compare_vector ,
291274 matched : & mut state. match_vector ,
@@ -294,7 +277,7 @@ impl<'a> TableAdapter for AdapterImpl<'a> {
294277 . row_match_columns (
295278 self . group_columns ,
296279 & self . payload . row_layout ,
297- ( count , no_match_count) ,
280+ ( need_compare_count , no_match_count) ,
298281 )
299282 }
300283}
You can’t perform that action at this time.
0 commit comments