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

serialization occupy position

Browse Source
This commit is contained in:
sdc
2025-03-11 04:16:15 +00:00
committed by ob-robot
parent 15fea3b039
commit ae3370491d
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/sql/engine/ob_physical_plan.cpp
View File

@ -137,7 +137,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT *
insertup_can_do_gts_opt_(false),
px_node_policy_(ObPxNodePolicy::INVALID),
px_node_addrs_(&allocator_),
px_node_count_(ObPxNodeHint::UNSET_PX_NODE_COUNT)
px_node_count_(ObPxNodeHint::UNSET_PX_NODE_COUNT),
px_worker_share_plan_enabled_(false)
{
}
@ -252,6 +253,7 @@ void ObPhysicalPlan::reset()
px_node_policy_ = ObPxNodePolicy::INVALID;
px_node_count_ = ObPxNodeHint::UNSET_PX_NODE_COUNT;
px_node_addrs_.reset();
px_worker_share_plan_enabled_ = false;
}
void ObPhysicalPlan::destroy()
{
@ -898,7 +900,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan,
px_parallel_rule_,
px_node_policy_,
px_node_addrs_,
px_node_count_);
px_node_count_,
px_worker_share_plan_enabled_);
int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos,
ObSchemaGetterGuard &schema_guard)

1
src/sql/engine/ob_physical_plan.h
View File

@ -782,6 +782,7 @@ private:
ObPxNodePolicy px_node_policy_;
common::ObFixedArray<common::ObAddr, common::ObIAllocator> px_node_addrs_;
int64_t px_node_count_;
int64_t px_worker_share_plan_enabled_;
};
inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)