From cb01ea1a03fa9b41b7cbee1db1cef8317824c2a1 Mon Sep 17 00:00:00 2001
From: Richard <richard.baah@datadoghq.com>
Date: Mon, 6 Jul 2026 10:35:35 -0400
Subject: [PATCH]  add short circut for primitive vectorized equal to

---
 .../src/aggregates/group_values/multi_group_by/primitive.rs    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/primitive.rs b/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/primitive.rs
index 068b849cb240f..eef8f3559e9d9 100644
--- a/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/primitive.rs
+++ b/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/primitive.rs
@@ -83,6 +83,9 @@ where
 
         for (i, (&lhs_row, &rhs_row)) in lhs_rows.iter().zip(rhs_rows.iter()).enumerate()
         {
+            if !equal_to_results.get_bit(i) {
+                continue;
+            }
             let left = if cfg!(debug_assertions) {
                 self.group_values[lhs_row]
             } else {