adaptive join placeholder

This commit is contained in:
qingsuijiu
2024-07-25 08:16:14 +00:00
committed by ob-robot
parent 8f932a36f2
commit 933fc045bf
2 changed files with 5 additions and 2 deletions

View File

@ -109,7 +109,8 @@ ObHashJoinSpec::ObHashJoinSpec(common::ObIAllocator &alloc, const ObPhyOperatorT
is_shared_ht_(false), is_shared_ht_(false),
is_ns_equal_cond_(alloc), is_ns_equal_cond_(alloc),
adaptive_hj_scan_cols_(alloc), adaptive_hj_scan_cols_(alloc),
adaptive_nlj_scan_cols_(alloc) adaptive_nlj_scan_cols_(alloc),
is_adaptive_(false)
{ {
} }
@ -123,7 +124,8 @@ OB_SERIALIZE_MEMBER((ObHashJoinSpec, ObJoinSpec),
is_shared_ht_, is_shared_ht_,
is_ns_equal_cond_, is_ns_equal_cond_,
adaptive_hj_scan_cols_, adaptive_hj_scan_cols_,
adaptive_nlj_scan_cols_); adaptive_nlj_scan_cols_,
is_adaptive_);
int ObHashJoinOp::PartHashJoinTable::init(ObIAllocator &alloc) int ObHashJoinOp::PartHashJoinTable::init(ObIAllocator &alloc)
{ {

View File

@ -277,6 +277,7 @@ public:
common::ObFixedArray<bool, common::ObIAllocator> is_ns_equal_cond_; common::ObFixedArray<bool, common::ObIAllocator> is_ns_equal_cond_;
ExprFixedArray adaptive_hj_scan_cols_; ExprFixedArray adaptive_hj_scan_cols_;
ExprFixedArray adaptive_nlj_scan_cols_; ExprFixedArray adaptive_nlj_scan_cols_;
bool is_adaptive_;
}; };
// hash join has no expression result overwrite problem: // hash join has no expression result overwrite problem: