Feat/tpcc dual #302

KKould · 2026-01-17T07:01:02Z

What problem does this PR solve?

feat:

A Dual parameter has been added to compare results between KiteSQL and SQLite in-memory mode in TPCC to verify the correctness of the results (the default is to run for only 60 seconds).
Add StreamDistinct to leverage the ordered options of the upstream schedule for efficient deduplication(Similar to SortElimination).
The ConstantCalculator has been optimized by directly rewriting Cast Constant as Constant.

fix:

Fixed an issue where incorrect results were caused by the primary key index still using index cover.

Code changes

Has Rust code change
Has CI related scripts change

Check List

Tests

Unit test
Integration test
Manual test (add detailed scripts or steps below)
No code

Side effects

Performance regression: Consumes more CPU
Performance regression: Consumes more Memory
Breaking backward compatibility

Note for reviewer

KKould · 2026-01-17T07:12:36Z

src/execution/dql/aggregate/stream_distinct.rs

+
+                if last_keys.as_ref() != Some(&group_keys) {
+                    last_keys = Some(group_keys.clone());
+                    co.yield_(Ok(Tuple::new(None, group_keys))).await;


lost PrimaryKey

KKould · 2026-01-17T07:38:51Z

src/expression/simplify.rs

+
+                if let ScalarExpression::Constant(value) = arg_expr.as_ref() {
+                    let casted = value.clone().cast(ty)?;
+                    let _ = mem::replace(expr, ScalarExpression::Constant(casted));


replace it first to avoid copying values

src/optimizer/rule/normalization/agg_elimination.rs

tests/slt/where_by_index.slt

KKould · 2026-01-17T07:50:41Z

tpcc/src/backend/dual.rs

+    }
+}
+
+#[cfg(test)]


tpcc/src/load.rs

tpcc/src/main.rs

KKould added 3 commits January 17, 2026 14:46

refactor: tpcc display & add dual for verification result

00ef8df

fix: stock level distinct case on dual

a8f96b1

feat: impl StreamDistinct & elimination plan constant cast

abcb351