From 7f4e40e3f4f745fc3b9486c32488fd4e9b37a466 Mon Sep 17 00:00:00 2001 From: GongYusen <986957406@qq.com> Date: Fri, 1 Nov 2024 08:43:49 +0000 Subject: [PATCH] The placeholder of MergeJoinVecSpec's serialization function modification --- src/sql/engine/join/ob_merge_join_vec_op.cpp | 6 +++++- src/sql/engine/join/ob_merge_join_vec_op.h | 10 +++++++++- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/src/sql/engine/join/ob_merge_join_vec_op.cpp b/src/sql/engine/join/ob_merge_join_vec_op.cpp index 750fdd01b..dede222ac 100644 --- a/src/sql/engine/join/ob_merge_join_vec_op.cpp +++ b/src/sql/engine/join/ob_merge_join_vec_op.cpp @@ -39,7 +39,11 @@ OB_SERIALIZE_MEMBER((ObMergeJoinVecSpec, ObJoinVecSpec), equal_cond_infos_, merge_directions_, left_child_fetcher_all_exprs_, - right_child_fetcher_all_exprs_); + right_child_fetcher_all_exprs_, + left_child_fetcher_equal_keys_, + right_child_fetcher_equal_keys_, + left_child_fetcher_equal_keys_idx_, + right_child_fetcher_equal_keys_idx_); OB_SERIALIZE_MEMBER(ObMergeJoinVecSpec::EqualConditionInfo, expr_, ser_eval_func_, is_opposite_); const int64_t ObMergeJoinVecSpec::MERGE_DIRECTION_ASC = 1; diff --git a/src/sql/engine/join/ob_merge_join_vec_op.h b/src/sql/engine/join/ob_merge_join_vec_op.h index 2885f6b33..9acd5fd9a 100644 --- a/src/sql/engine/join/ob_merge_join_vec_op.h +++ b/src/sql/engine/join/ob_merge_join_vec_op.h @@ -64,7 +64,11 @@ public: equal_cond_infos_(alloc), merge_directions_(alloc), left_child_fetcher_all_exprs_(alloc), - right_child_fetcher_all_exprs_(alloc) + right_child_fetcher_all_exprs_(alloc), + left_child_fetcher_equal_keys_(alloc), + right_child_fetcher_equal_keys_(alloc), + left_child_fetcher_equal_keys_idx_(alloc), + right_child_fetcher_equal_keys_idx_(alloc) {} virtual ~ObMergeJoinVecSpec() {}; @@ -96,6 +100,10 @@ public: common::ObFixedArray merge_directions_; ExprFixedArray left_child_fetcher_all_exprs_; ExprFixedArray right_child_fetcher_all_exprs_; + ExprFixedArray left_child_fetcher_equal_keys_; + ExprFixedArray right_child_fetcher_equal_keys_; + common::ObFixedArray left_child_fetcher_equal_keys_idx_; + common::ObFixedArray right_child_fetcher_equal_keys_idx_; private: DISALLOW_COPY_AND_ASSIGN(ObMergeJoinVecSpec);