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

Add placeholder for incremental direct load

Browse Source
This commit is contained in:
suz-yang
2024-04-08 03:15:44 +00:00
committed by ob-robot
parent 059435306e
commit eb5bafc586
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

@ -137,7 +137,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT *
all_local_session_vars_(&allocator_),
udf_has_dml_stmt_(false),
mview_ids_(&allocator_),
enable_inc_direct_load_(false)
enable_inc_direct_load_(false),
enable_replace_(false)
{
}
@ -235,6 +236,7 @@ void ObPhysicalPlan::reset()
udf_has_dml_stmt_ = false;
mview_ids_.reset();
enable_inc_direct_load_ = false;
enable_replace_ = false;
}
void ObPhysicalPlan::destroy()
{
@ -797,7 +799,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan,
udf_has_dml_stmt_,
stat_.format_sql_id_,
mview_ids_,
enable_inc_direct_load_);
enable_inc_direct_load_,
enable_replace_);
int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos,
ObSchemaGetterGuard &schema_guard)

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

@ -371,6 +371,11 @@ public:
{
enable_inc_direct_load_ = enable_inc_direct_load;
}
inline bool get_enable_replace() const { return enable_replace_; }
inline void set_enable_replace(const bool enable_replace)
{
enable_replace_ = enable_replace;
}
public:
int inc_concurrent_num();
@ -691,6 +696,7 @@ public:
private:
common::ObFixedArray<uint64_t, common::ObIAllocator> mview_ids_;
bool enable_inc_direct_load_; // for incremental direct load
bool enable_replace_; // for incremental direct load
};
inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)