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

Add place holder for incremental direct load

Browse Source
This commit is contained in:
leftgeek
2024-03-18 11:45:33 +00:00
committed by ob-robot
parent 86dfba9c3b
commit fd93c974af
2 changed files with 11 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

@ -136,7 +136,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT *
disable_auto_memory_mgr_(false), disable_auto_memory_mgr_(false),
all_local_session_vars_(&allocator_), all_local_session_vars_(&allocator_),
udf_has_dml_stmt_(false), udf_has_dml_stmt_(false),
mview_ids_(&allocator_) mview_ids_(&allocator_),
enable_inc_direct_load_(false)
{ {
} }
@ -233,6 +234,7 @@ void ObPhysicalPlan::reset()
all_local_session_vars_.reset(); all_local_session_vars_.reset();
udf_has_dml_stmt_ = false; udf_has_dml_stmt_ = false;
mview_ids_.reset(); mview_ids_.reset();
enable_inc_direct_load_ = false;
} }
void ObPhysicalPlan::destroy() void ObPhysicalPlan::destroy()
{ {
@ -794,7 +796,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan,
disable_auto_memory_mgr_, disable_auto_memory_mgr_,
udf_has_dml_stmt_, udf_has_dml_stmt_,
stat_.format_sql_id_, stat_.format_sql_id_,
mview_ids_); mview_ids_,
enable_inc_direct_load_);
int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos, int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos,
ObSchemaGetterGuard &schema_guard) ObSchemaGetterGuard &schema_guard)

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

@ -363,6 +363,11 @@ public:
} }
inline int64_t get_plan_error_cnt() { return stat_.evolution_stat_.error_cnt_; } inline int64_t get_plan_error_cnt() { return stat_.evolution_stat_.error_cnt_; }
inline void update_plan_error_cnt() { ATOMIC_INC(&(stat_.evolution_stat_.error_cnt_)); } inline void update_plan_error_cnt() { ATOMIC_INC(&(stat_.evolution_stat_.error_cnt_)); }
inline bool get_enable_inc_direct_load() const { return enable_inc_direct_load_; }
inline void set_enable_inc_direct_load(const bool enable_inc_direct_load)
{
enable_inc_direct_load_ = enable_inc_direct_load;
}
public: public:
int inc_concurrent_num(); int inc_concurrent_num();
@ -681,6 +686,7 @@ public:
bool udf_has_dml_stmt_; bool udf_has_dml_stmt_;
private: private:
common::ObFixedArray<uint64_t, common::ObIAllocator> mview_ids_; common::ObFixedArray<uint64_t, common::ObIAllocator> mview_ids_;
bool enable_inc_direct_load_; // for incremental direct load
}; };
inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id) inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)