diff --git a/src/sql/das/ob_das_scan_op.cpp b/src/sql/das/ob_das_scan_op.cpp index 057703c9ae..c0f0fdba51 100644 --- a/src/sql/das/ob_das_scan_op.cpp +++ b/src/sql/das/ob_das_scan_op.cpp @@ -1121,7 +1121,11 @@ ObDASScanResult::ObDASScanResult() eval_ctx_(nullptr), extra_result_(nullptr), need_check_output_datum_(false), - enable_rich_format_(false) + enable_rich_format_(false), + io_read_bytes_(0), + ssstore_read_bytes_(0), + ssstore_read_row_cnt_(0), + memstore_read_row_cnt_(0) { } @@ -1271,7 +1275,11 @@ int ObDASScanResult::link_extra_result(ObDASExtraData &extra_result) OB_SERIALIZE_MEMBER((ObDASScanResult, ObIDASTaskResult), datum_store_, enable_rich_format_, - vec_row_store_); + vec_row_store_, + io_read_bytes_, + ssstore_read_bytes_, + ssstore_read_row_cnt_, + memstore_read_row_cnt_); ObLocalIndexLookupOp::~ObLocalIndexLookupOp() { diff --git a/src/sql/das/ob_das_scan_op.h b/src/sql/das/ob_das_scan_op.h index cf6b7fe6d2..60776225b7 100644 --- a/src/sql/das/ob_das_scan_op.h +++ b/src/sql/das/ob_das_scan_op.h @@ -291,7 +291,11 @@ public: K_(datum_store), KPC_(output_exprs), K_(enable_rich_format), - K_(vec_row_store)); + K_(vec_row_store), + K_(io_read_bytes), + K_(ssstore_read_bytes), + K_(ssstore_read_row_cnt), + K_(memstore_read_row_cnt)); private: ObChunkDatumStore datum_store_; ObChunkDatumStore::Iterator result_iter_; @@ -302,6 +306,10 @@ private: ObDASExtraData *extra_result_; bool need_check_output_datum_; bool enable_rich_format_; + int64_t io_read_bytes_; + int64_t ssstore_read_bytes_; + int64_t ssstore_read_row_cnt_; + int64_t memstore_read_row_cnt_; }; class ObLocalIndexLookupOp : public common::ObNewRowIterator, public ObIndexLookupOpImpl diff --git a/src/sql/das/ob_das_task.cpp b/src/sql/das/ob_das_task.cpp index a88e06968c..192ebfba0b 100644 --- a/src/sql/das/ob_das_task.cpp +++ b/src/sql/das/ob_das_task.cpp @@ -619,7 +619,11 @@ int ObDASDataEraseReq::init(const uint64_t tenant_id, const int64_t task_id) OB_SERIALIZE_MEMBER(ObDASDataFetchRes, datum_store_, tenant_id_, task_id_, has_more_, - enable_rich_format_, vec_row_store_); + enable_rich_format_, vec_row_store_, + io_read_bytes_, + ssstore_read_bytes_, + ssstore_read_row_cnt_, + memstore_read_row_cnt_); ObDASDataFetchRes::ObDASDataFetchRes() : datum_store_("DASDataFetch"), @@ -627,7 +631,11 @@ ObDASDataFetchRes::ObDASDataFetchRes() task_id_(0), has_more_(false), enable_rich_format_(false), - vec_row_store_() + vec_row_store_(), + io_read_bytes_(0), + ssstore_read_bytes_(0), + ssstore_read_row_cnt_(0), + memstore_read_row_cnt_(0) { } diff --git a/src/sql/das/ob_das_task.h b/src/sql/das/ob_das_task.h index 56ec19994f..385057c63f 100644 --- a/src/sql/das/ob_das_task.h +++ b/src/sql/das/ob_das_task.h @@ -566,7 +566,9 @@ public: void set_has_more(const bool has_more) { has_more_ = has_more; } bool has_more() { return has_more_; } int64_t get_task_id() const { return task_id_; } - TO_STRING_KV(K_(tenant_id), K_(task_id), K_(has_more), K_(datum_store)); + TO_STRING_KV(K_(tenant_id), K_(task_id), K_(has_more), K_(datum_store), + K_(io_read_bytes), K_(ssstore_read_bytes), + K_(ssstore_read_row_cnt), K_(memstore_read_row_cnt)); private: ObChunkDatumStore datum_store_; uint64_t tenant_id_; @@ -574,6 +576,10 @@ private: bool has_more_; bool enable_rich_format_; ObTempRowStore vec_row_store_; + int64_t io_read_bytes_; + int64_t ssstore_read_bytes_; + int64_t ssstore_read_row_cnt_; + int64_t memstore_read_row_cnt_; }; class ObDASDataEraseReq