hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

RCTE Union Distinct serialization occupy

Browse Source
This commit is contained in:
obdev
2024-06-25 12:39:11 +00:00
committed by ob-robot
parent 861547704d
commit 3558eba951
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/engine/recursive_cte/ob_fake_cte_table_op.cpp
View File

@ -23,7 +23,8 @@ OB_SERIALIZE_MEMBER((ObFakeCTETableSpec, ObOpSpec),
column_involved_offset_, column_involved_offset_,
column_involved_exprs_, column_involved_exprs_,
is_bulk_search_, is_bulk_search_,
identify_seq_expr_); identify_seq_expr_,
is_union_distinct_);
int ObFakeCTETableOp::inner_get_next_row() int ObFakeCTETableOp::inner_get_next_row()
{ {

5
src/sql/engine/recursive_cte/ob_fake_cte_table_op.h
View File

@ -33,13 +33,13 @@ class ObFakeCTETableSpec : public ObOpSpec
public: public:
explicit ObFakeCTETableSpec(common::ObIAllocator &alloc, const ObPhyOperatorType type) explicit ObFakeCTETableSpec(common::ObIAllocator &alloc, const ObPhyOperatorType type)
: ObOpSpec(alloc, type), column_involved_offset_(alloc), column_involved_exprs_(alloc), : 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, INHERIT_TO_STRING_KV("op_spec", ObOpSpec,
K_(column_involved_offset), K_(column_involved_exprs), 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() {} virtual ~ObFakeCTETableSpec() {}
@ -49,6 +49,7 @@ public:
//for breadth search first //for breadth search first
bool is_bulk_search_; bool is_bulk_search_;
ObExpr *identify_seq_expr_; ObExpr *identify_seq_expr_;
bool is_union_distinct_;
}; };
class ObFakeCTETableOp : public ObOperator class ObFakeCTETableOp : public ObOperator