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

add trans_result in ObDirectLoadControlCommitRes

Browse Source
This commit is contained in:
coolfishchen
2024-04-20 15:15:24 +00:00
committed by ob-robot
parent d9824868ff
commit 3dd0008dc9
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/observer/table_load/control/ob_table_load_control_rpc_struct.cpp
View File

@ -193,7 +193,8 @@ OB_SERIALIZE_MEMBER(ObDirectLoadControlCommitArg,
OB_SERIALIZE_MEMBER(ObDirectLoadControlCommitRes, OB_SERIALIZE_MEMBER(ObDirectLoadControlCommitRes,
result_info_, result_info_,
sql_statistics_); sql_statistics_,
trans_result_);
// abort // abort
OB_SERIALIZE_MEMBER(ObDirectLoadControlAbortArg, OB_SERIALIZE_MEMBER(ObDirectLoadControlAbortArg,

2
src/observer/table_load/control/ob_table_load_control_rpc_struct.h
View File

@ -22,6 +22,7 @@
#include "sql/session/ob_sql_session_mgr.h" #include "sql/session/ob_sql_session_mgr.h"
#include "observer/table_load/ob_table_load_struct.h" #include "observer/table_load/ob_table_load_struct.h"
#include "storage/direct_load/ob_direct_load_struct.h" #include "storage/direct_load/ob_direct_load_struct.h"
#include "storage/tx/ob_trans_define_v4.h"
namespace oceanbase namespace oceanbase
{ {
@ -254,6 +255,7 @@ public:
public: public:
table::ObTableLoadResultInfo result_info_; table::ObTableLoadResultInfo result_info_;
table::ObTableLoadSqlStatistics sql_statistics_; table::ObTableLoadSqlStatistics sql_statistics_;
transaction::ObTxExecResult trans_result_;
}; };
class ObDirectLoadControlAbortArg final class ObDirectLoadControlAbortArg final