fix(clickhouse): validate coverage for every join input

control_plane/Cargo.toml

@@ -91,18 +91,18 @@ asap_types.workspace = true
 # scaffolding, unaware that `data_plane`'s `summary_executor.rs` in *this*
 # repo is a real one. Vendored locally instead of chased upstream -- see
 # `data_plane/src/query_engines/asap_query_engine/summary_exec.rs`.
-planner-types = { package = "asap-types", git = "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/ProjectASAP/ASAPPlanner", rev = "26e580710cf9b44b282598719d6c5ea9a9cc62be" }
-asap-aware-mapping = { git = "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/ProjectASAP/ASAPPlanner", rev = "26e580710cf9b44b282598719d6c5ea9a9cc62be" }
+planner-types = { package = "asap-types", git = "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/ProjectASAP/ASAPPlanner", rev = "3dda28032c2a2badb64bf5358e0f40fef9918227" }
+asap-aware-mapping = { git = "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/ProjectASAP/ASAPPlanner", rev = "3dda28032c2a2badb64bf5358e0f40fef9918227" }
 
 # L1 adoption (design-target-architecture.md Part B): the PromQL front
 # end itself, replacing control_plane's own query_parser/promql.rs.
 # Pinned via `rev`, not a floating branch reference. Same rev as
 # `planner-types`/`asap-aware-mapping` above -- these three MUST move
 # together (two revs of the same upstream repo's types in one workspace
 # resolve to distinct Rust types that won't unify).
-asap-frontend-promql = { git = "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/ProjectASAP/ASAPPlanner", rev = "26e580710cf9b44b282598719d6c5ea9a9cc62be" }
-asap-frontend-metricsql = { git = "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/ProjectASAP/ASAPPlanner", rev = "26e580710cf9b44b282598719d6c5ea9a9cc62be" }
-asap-frontend-sql = { git = "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/ProjectASAP/ASAPPlanner", rev = "26e580710cf9b44b282598719d6c5ea9a9cc62be" }
+asap-frontend-promql = { git = "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/ProjectASAP/ASAPPlanner", rev = "3dda28032c2a2badb64bf5358e0f40fef9918227" }
+asap-frontend-metricsql = { git = "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/ProjectASAP/ASAPPlanner", rev = "3dda28032c2a2badb64bf5358e0f40fef9918227" }
+asap-frontend-sql = { git = "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/ProjectASAP/ASAPPlanner", rev = "3dda28032c2a2badb64bf5358e0f40fef9918227" }
 
 [dev-dependencies]
 tokio = { version = "1", features = ["full", "test-util"] }

control_plane/examples/calibration_candidates.rs

@@ -74,6 +74,16 @@ fn planner_forest(queries: &[control_plane::physical::compiler::PlanningQuery])
                 vec![outer, inner],
                 json!({"key_debug":format!("{key:?}"),"family_debug":format!("{family:?}")}),
             ),
+            SummaryExpr::RelationalJoin {
+                left,
+                right,
+                kind,
+                pred,
+            } => (
+                "RelationalJoin",
+                vec![left, right],
+                json!({"kind_debug":format!("{kind:?}"),"predicate_debug":format!("{pred:?}")}),
+            ),
             SummaryExpr::SummarySubtract { left, right } => {
                 ("SummarySubtract", vec![left, right], json!({}))
             }

control_plane/examples/offline_planner_replay.rs

@@ -73,6 +73,11 @@ fn inspect(
             left: lhs,
             right: rhs,
         }
+        | SummaryExpr::RelationalJoin {
+            left: lhs,
+            right: rhs,
+            ..
+        }
         | SummaryExpr::BinaryOp { lhs, rhs, .. } => {
             inspect(lhs, model, seen, states, raw);
             inspect(rhs, model, seen, states, raw);

control_plane/src/emit/mod.rs

@@ -326,6 +326,7 @@ fn extract_from_node(node: &Rc<SummaryNode>) -> Option<SketchAlgorithm> {
         // Not surfaced by any `Bind*` path yet (gated on rules that
         // haven't landed — see `deployment_expr.rs`'s module docs).
         SummaryExpr::BinaryOp { .. }
+        | SummaryExpr::RelationalJoin { .. }
         | SummaryExpr::SummaryJoin { .. }
         | SummaryExpr::SummarySubtract { .. }
         | SummaryExpr::SummaryDelete { .. }

control_plane/src/opamp/mod.rs

@@ -1027,9 +1027,9 @@ mod tests {
                 abstract_window_framework:
                     planner_types::post_asap::SummaryWindowFramework::Tumbling,
                 window_implementation_id: "collector-tumbling-v1".into(),
-                pane_secs: 60,
+                slide_secs: 60,
                 pane_origin_ms: Some(0),
-                state_layout: "anchored-pane-v1".into(),
+                window_layout: asap_types::WindowMaterializationLayout::Pane { pane_secs: 60 },
                 evidence_source: None,
                 lifecycle: crate::physical::compiler::CollectorLifecycle {
                     kind: "continuously_maintained".into(),

control_plane/src/physical/colored_dag/allocator.rs

@@ -184,6 +184,13 @@ impl ThreeStageWalker {
                 }
                 StageId::Backend
             }
+            SummaryExpr::RelationalJoin { left, right, .. } => {
+                for child in [left, right] {
+                    let (cid, _) = self.visit_l4node(child)?;
+                    self.dag.edges.push((id, cid));
+                }
+                StageId::Backend
+            }
             SummaryExpr::ValueOperation { child, timing, .. } => {
                 let (cid, child_stage) = self.visit_l4node(child)?;
                 self.dag.edges.push((id, cid));

control_plane/src/physical/colored_dag/emitter.rs

@@ -117,6 +117,7 @@ fn classify(expr: &PhysicalExpr) -> NodeKind<'_> {
             SummaryExpr::SummaryEstimate { query, .. } => NodeKind::SketchEstimate { query },
             SummaryExpr::SummaryMerge { .. } => NodeKind::SketchMerge,
             SummaryExpr::BinaryOp { .. }
+            | SummaryExpr::RelationalJoin { .. }
             | SummaryExpr::CandidateTopK { .. }
             | SummaryExpr::ValueOperation { .. }
             | SummaryExpr::SummaryJoin { .. }