From 52148e8d8300d49e331519b4ff22c1f7dddfaa82 Mon Sep 17 00:00:00 2001 From: Michael Xu Date: Wed, 24 Apr 2024 22:46:08 -0400 Subject: [PATCH] update comment; tiny refactor --- src/frontend/src/planner/relation.rs | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/frontend/src/planner/relation.rs b/src/frontend/src/planner/relation.rs index bf6173962b9ea..0b66e4e743a0d 100644 --- a/src/frontend/src/planner/relation.rs +++ b/src/frontend/src/planner/relation.rs @@ -57,9 +57,7 @@ impl Planner { Relation::Watermark(tf) => self.plan_watermark(*tf), // note that rcte (i.e., RecursiveUnion) is included *implicitly* in share. Relation::Share(share) => self.plan_share(*share), - Relation::BackCteRef(..) => { - bail_not_implemented!(issue = 15135, "recursive CTE is not supported") - } + Relation::BackCteRef(cte_ref) => self.plan_cte_ref(*cte_ref) } } @@ -233,6 +231,7 @@ impl Planner { Some(result) => Ok(result.clone()), } } + // for the recursive union in rcte Either::Right(recursive_union) => { self.plan_recursive_union(*recursive_union.base, *recursive_union.recursive) } @@ -243,9 +242,8 @@ impl Planner { todo!("plan watermark"); } - #[allow(dead_code)] pub(super) fn plan_cte_ref(&mut self, _cte_ref: BoundBackCteRef) -> Result { - todo!("plan cte ref"); + bail_not_implemented!(issue = 15135, "recursive CTE not supported") } fn collect_col_data_types_for_tumble_window(relation: &Relation) -> Result> {