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

add placeholder for rowkey_doc & doc_rowkey data complement

Browse Source
This commit is contained in:
zhenhan.gong@gmail.com 2024-07-11 14:17:04 +00:00 committed by ob-robot
parent 0e9c4cda2b
commit bb0c7fdc29
3 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h vendored
View File

@ -1173,6 +1173,7 @@ PCODE_DEF(OB_GENERATE_AUX_INDEX_SCHEMA, 0x1626)
//PCODE_DEF(OB_GET_SS_MICRO_BLOCK_META, 0x162A)
//PCODE_DEF(OB_GET_LS_REQUIRED_SIZE, 0x162B)
//PCODE_DEF(OB_DEL_SS_TABLET_META, 0x162C)
//PCODE_DEF(OB_CHECK_AUX_INDEX_SCHEMA_EXIST, 0x162D)
//**** 注意：在此行之前增加新的RPC ID ******
//

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

@ -144,7 +144,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT *
insert_overwrite_(false),
online_sample_percent_(1.),
can_set_feedback_info_(true),
need_switch_to_table_lock_worker_(false)
need_switch_to_table_lock_worker_(false),
data_complement_gen_doc_id_(false)
{
}
@ -248,6 +249,7 @@ void ObPhysicalPlan::reset()
online_sample_percent_ = 1.;
can_set_feedback_info_.store(true);
need_switch_to_table_lock_worker_ = false;
data_complement_gen_doc_id_ = false;
}
void ObPhysicalPlan::destroy()
{
@ -823,7 +825,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan,
immediate_refresh_external_table_ids_,
insert_overwrite_,
online_sample_percent_,
need_switch_to_table_lock_worker_);
need_switch_to_table_lock_worker_,
data_complement_gen_doc_id_);
int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos,
ObSchemaGetterGuard &schema_guard)

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

@ -711,6 +711,7 @@ private:
double online_sample_percent_; // for incremental direct load
std::atomic<bool> can_set_feedback_info_;
bool need_switch_to_table_lock_worker_; // for table lock switch worker thread
bool data_complement_gen_doc_id_;
};
inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)