master place_holder for pdml check_affected_row

src/sql/engine/ob_exec_feedback_info.cpp

@@ -25,7 +25,8 @@ OB_SERIALIZE_MEMBER(ObExecFeedbackNode,
                     op_last_row_time_,
                     db_time_,
                     block_time_,
-                    worker_count_);
+                    worker_count_,
+                    pdml_op_write_rows_);
 
 OB_SERIALIZE_MEMBER(ObExecFeedbackInfo,
                     nodes_,

src/sql/engine/ob_exec_feedback_info.h

@@ -29,10 +29,10 @@ struct ObExecFeedbackNode final
 public:
   ObExecFeedbackNode(int64_t op_id) : op_id_(op_id), output_row_count_(0),
       op_open_time_(INT64_MAX), op_close_time_(0), op_first_row_time_(INT64_MAX),
-      op_last_row_time_(0), db_time_(0),  block_time_(0), worker_count_(0) {}
+      op_last_row_time_(0), db_time_(0),  block_time_(0), worker_count_(0), pdml_op_write_rows_(0) {}
   ObExecFeedbackNode() : op_id_(OB_INVALID_ID), output_row_count_(0),
       op_open_time_(INT64_MAX), op_close_time_(0), op_first_row_time_(INT64_MAX),
-      op_last_row_time_(0), db_time_(0),  block_time_(0), worker_count_(0) {}
+      op_last_row_time_(0), db_time_(0),  block_time_(0), worker_count_(0), pdml_op_write_rows_(0) {}
   ~ObExecFeedbackNode() {}
   TO_STRING_KV(K_(op_id), K_(output_row_count), K_(op_open_time),
                K_(op_close_time), K_(op_first_row_time), K_(op_last_row_time),
@@ -47,6 +47,7 @@ public:
   int64_t db_time_;    // rdtsc cpu cycles spend on this op, include cpu instructions & io
   int64_t block_time_; // rdtsc cpu cycles wait for network, io etc
   int64_t worker_count_;
+  int64_t pdml_op_write_rows_;
 };
 
 class ObExecFeedbackInfo final

src/sql/engine/ob_physical_plan_ctx.cpp

@@ -126,7 +126,8 @@ ObPhysicalPlanCtx::ObPhysicalPlanCtx(common::ObIAllocator &allocator)
       main_xa_trans_branch_(false),
       total_memstore_read_row_count_(0),
       total_ssstore_read_row_count_(0),
-      is_direct_insert_plan_(false)
+      is_direct_insert_plan_(false),
+      check_pdml_affected_rows_(false)
 {
 }
 
@@ -780,6 +781,7 @@ OB_DEF_SERIALIZE(ObPhysicalPlanCtx)
   OB_UNIS_ENCODE(mview_ids_);
   OB_UNIS_ENCODE(last_refresh_scns_);
   OB_UNIS_ENCODE(is_direct_insert_plan_);
+  OB_UNIS_ENCODE(check_pdml_affected_rows_);
   return ret;
 }
 
@@ -880,6 +882,7 @@ OB_DEF_SERIALIZE_SIZE(ObPhysicalPlanCtx)
   OB_UNIS_ADD_LEN(mview_ids_);
   OB_UNIS_ADD_LEN(last_refresh_scns_);
   OB_UNIS_ADD_LEN(is_direct_insert_plan_);
+  OB_UNIS_ADD_LEN(check_pdml_affected_rows_);
   return len;
 }
 
@@ -1006,6 +1009,7 @@ OB_DEF_DESERIALIZE(ObPhysicalPlanCtx)
   OB_UNIS_DECODE(mview_ids_);
   OB_UNIS_DECODE(last_refresh_scns_);
   OB_UNIS_DECODE(is_direct_insert_plan_);
+  OB_UNIS_DECODE(check_pdml_affected_rows_);
   return ret;
 }
 

src/sql/engine/ob_physical_plan_ctx.h

@@ -689,6 +689,7 @@ private:
   int64_t total_memstore_read_row_count_;
   int64_t total_ssstore_read_row_count_;
   bool is_direct_insert_plan_; // for direct load: insert into/overwrite select
+  bool check_pdml_affected_rows_; // now only worked for pdml checking affected_rows
 };
 
 }