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

DDLTaskSerializedField placehold

Browse Source
This commit is contained in:
fanfangzhou
2024-05-13 13:48:08 +00:00
committed by ob-robot
parent 97dbfd2f97
commit bdee14fc0a
2 changed files with 20 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/rootserver/ddl_task/ob_ddl_task.cpp
View File

@ -133,7 +133,9 @@ ObDDLTaskSerializeField::ObDDLTaskSerializeField(const int64_t task_version,
const uint64_t data_format_version,
const int64_t consumer_group_id,
const bool is_abort,
const int32_t sub_task_trace_id)
const int32_t sub_task_trace_id,
const bool is_unique_index,
const bool is_global_index)
{
task_version_ = task_version;
parallelism_ = parallelism;
@ -141,6 +143,8 @@ ObDDLTaskSerializeField::ObDDLTaskSerializeField(const int64_t task_version,
consumer_group_id_ = consumer_group_id;
is_abort_ = is_abort;
sub_task_trace_id_ = sub_task_trace_id;
is_unique_index_ = is_unique_index;
is_global_index_ = is_global_index;
}
void ObDDLTaskSerializeField::reset()
@ -151,6 +155,8 @@ void ObDDLTaskSerializeField::reset()
consumer_group_id_ = 0;
is_abort_ = false;
sub_task_trace_id_ = 0;
is_unique_index_ = false;
is_global_index_ = false;
}
OB_SERIALIZE_MEMBER(ObDDLTaskSerializeField,
@ -159,7 +165,9 @@ OB_SERIALIZE_MEMBER(ObDDLTaskSerializeField,
data_format_version_,
consumer_group_id_,
is_abort_,
sub_task_trace_id_);
sub_task_trace_id_,
is_unique_index_,
is_global_index_);
ObCreateDDLTaskParam::ObCreateDDLTaskParam()
: sub_task_trace_id_(0), tenant_id_(OB_INVALID_ID), object_id_(OB_INVALID_ID), schema_version_(0), parallelism_(0),

13
src/rootserver/ddl_task/ob_ddl_task.h
View File

@ -139,14 +139,19 @@ struct ObDDLTaskSerializeField final
{
OB_UNIS_VERSION(1);
public:
TO_STRING_KV(K_(task_version), K_(parallelism), K_(data_format_version), K_(consumer_group_id), K_(is_abort), K_(sub_task_trace_id));
ObDDLTaskSerializeField() : task_version_(0), parallelism_(0), data_format_version_(0), consumer_group_id_(0), is_abort_(false), sub_task_trace_id_(0) {}
TO_STRING_KV(K_(task_version), K_(parallelism), K_(data_format_version), K_(consumer_group_id),
K_(is_abort), K_(sub_task_trace_id), K_(is_unique_index), K_(is_global_index));
ObDDLTaskSerializeField() : task_version_(0), parallelism_(0), data_format_version_(0),
consumer_group_id_(0), is_abort_(false), sub_task_trace_id_(0),
is_unique_index_(false), is_global_index_(false) {}
ObDDLTaskSerializeField(const int64_t task_version,
const int64_t parallelism,
const uint64_t data_format_version,
const int64_t consumer_group_id,
const bool is_abort,
const int32_t sub_task_trace_id);
const int32_t sub_task_trace_id,
const bool is_unique_index = false,
const bool is_global_index = false);
~ObDDLTaskSerializeField() = default;
void reset();
public:
@ -156,6 +161,8 @@ public:
int64_t consumer_group_id_;
bool is_abort_;
int32_t sub_task_trace_id_;
bool is_unique_index_;
bool is_global_index_;
};
struct ObCreateDDLTaskParam final