From 3558eba9515d0d2199570b6b8a61c2bb796261eb Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 25 Jun 2024 12:39:11 +0000 Subject: [PATCH] RCTE Union Distinct serialization occupy --- src/sql/engine/recursive_cte/ob_fake_cte_table_op.cpp | 3 ++- src/sql/engine/recursive_cte/ob_fake_cte_table_op.h | 5 +++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/src/sql/engine/recursive_cte/ob_fake_cte_table_op.cpp b/src/sql/engine/recursive_cte/ob_fake_cte_table_op.cpp index 536c770cd7..13337960c2 100644 --- a/src/sql/engine/recursive_cte/ob_fake_cte_table_op.cpp +++ b/src/sql/engine/recursive_cte/ob_fake_cte_table_op.cpp @@ -23,7 +23,8 @@ OB_SERIALIZE_MEMBER((ObFakeCTETableSpec, ObOpSpec), column_involved_offset_, column_involved_exprs_, is_bulk_search_, - identify_seq_expr_); + identify_seq_expr_, + is_union_distinct_); int ObFakeCTETableOp::inner_get_next_row() { diff --git a/src/sql/engine/recursive_cte/ob_fake_cte_table_op.h b/src/sql/engine/recursive_cte/ob_fake_cte_table_op.h index 6b1eaf47ec..83e484472f 100644 --- a/src/sql/engine/recursive_cte/ob_fake_cte_table_op.h +++ b/src/sql/engine/recursive_cte/ob_fake_cte_table_op.h @@ -33,13 +33,13 @@ class ObFakeCTETableSpec : public ObOpSpec public: explicit ObFakeCTETableSpec(common::ObIAllocator &alloc, const ObPhyOperatorType type) : ObOpSpec(alloc, type), column_involved_offset_(alloc), column_involved_exprs_(alloc), - is_bulk_search_(false), identify_seq_expr_(nullptr) + is_bulk_search_(false), identify_seq_expr_(nullptr), is_union_distinct_(false) { } INHERIT_TO_STRING_KV("op_spec", ObOpSpec, K_(column_involved_offset), K_(column_involved_exprs), - K_(is_bulk_search), K_(identify_seq_expr)); + K_(is_bulk_search), K_(identify_seq_expr), K_(is_union_distinct)); virtual ~ObFakeCTETableSpec() {} @@ -49,6 +49,7 @@ public: //for breadth search first bool is_bulk_search_; ObExpr *identify_seq_expr_; + bool is_union_distinct_; }; class ObFakeCTETableOp : public ObOperator