File tree 1 file changed +4
-5
lines changed
crates/core/src/subscription
1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -30,12 +30,9 @@ pub fn eval_delta<'a, Tx: Datastore + DeltaStore>(
30
30
let mut duplicate_rows_evaluated = 0 ;
31
31
let mut duplicate_rows_sent = 0 ;
32
32
33
- // Query plans for joins may return redundant rows,
34
- // but we track row counts to avoid sending them to clients.
35
- //
36
- // Single table plans will never return redundant rows,
37
- // so there's no need to track row counts.
38
33
if !plan. is_join ( ) {
34
+ // Single table plans will never return redundant rows,
35
+ // so there's no need to track row counts.
39
36
plan. for_each_insert ( tx, metrics, & mut |row| {
40
37
inserts. push ( row. into ( ) ) ;
41
38
Ok ( ( ) )
@@ -46,6 +43,8 @@ pub fn eval_delta<'a, Tx: Datastore + DeltaStore>(
46
43
Ok ( ( ) )
47
44
} ) ?;
48
45
} else {
46
+ // Query plans for joins may return redundant rows.
47
+ // We track row counts to avoid sending them to clients.
49
48
let mut insert_counts = HashMap :: new ( ) ;
50
49
let mut delete_counts = HashMap :: new ( ) ;
51
50
You can’t perform that action at this time.
0 commit comments