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

place holder for no logging

Browse Source
This commit is contained in:
AnimationFan 2024-10-16 14:16:48 +00:00 committed by ob-robot
parent 75d31ec0e2
commit 542619e673
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/share/ob_rpc_struct.cpp
View File

@ -8975,7 +8975,7 @@ OB_DEF_SERIALIZE(ObDDLBuildSingleReplicaRequestArg)
parallelism_, tablet_task_id_, data_format_version_, consumer_group_id_, dest_tenant_id_,
dest_ls_id_, dest_schema_version_,
compaction_scn_, can_reuse_macro_block_, split_sstable_type_,
lob_col_idxs_, parallel_datum_rowkey_list_);
lob_col_idxs_, parallel_datum_rowkey_list_, is_no_logging_);
return ret;
}
@ -8992,6 +8992,10 @@ OB_DEF_DESERIALIZE(ObDDLBuildSingleReplicaRequestArg)
rowkey_allocator_, buf, data_len, pos, parallel_datum_rowkey_list_))) {
LOG_WARN("deserialzie parallel info failed", K(ret));
}
if (OB_SUCC(ret)) {
LST_DO_CODE(is_no_logging_)
}
return ret;
}
@ -9003,7 +9007,7 @@ OB_DEF_SERIALIZE_SIZE(ObDDLBuildSingleReplicaRequestArg)
parallelism_, tablet_task_id_, data_format_version_, consumer_group_id_, dest_tenant_id_,
dest_ls_id_, dest_schema_version_,
compaction_scn_, can_reuse_macro_block_, split_sstable_type_,
lob_col_idxs_, parallel_datum_rowkey_list_);
lob_col_idxs_, parallel_datum_rowkey_list_, is_no_logging_);
return len;
}

5
src/share/ob_rpc_struct.h
View File

@ -10548,7 +10548,7 @@ public:
schema_version_(0), snapshot_version_(0), ddl_type_(0), task_id_(0), parallelism_(0), execution_id_(-1), tablet_task_id_(0),
data_format_version_(0), consumer_group_id_(0), dest_tenant_id_(OB_INVALID_ID), dest_ls_id_(), dest_schema_version_(0),
compaction_scn_(0), can_reuse_macro_block_(false), split_sstable_type_(share::ObSplitSSTableType::SPLIT_BOTH),
lob_col_idxs_(), parallel_datum_rowkey_list_()
lob_col_idxs_(), parallel_datum_rowkey_list_(), is_no_logging_(false)
{}
bool is_valid() const;
int assign(const ObDDLBuildSingleReplicaRequestArg &other);
@ -10557,7 +10557,7 @@ public:
K_(task_id), K_(parallelism), K_(execution_id), K_(tablet_task_id), K_(data_format_version),
K_(consumer_group_id), K_(dest_tenant_id), K_(dest_ls_id), K_(dest_schema_version),
K_(compaction_scn), K_(can_reuse_macro_block), K_(split_sstable_type), K_(lob_col_idxs),
K_(parallel_datum_rowkey_list));
K_(parallel_datum_rowkey_list), K_(is_no_logging));
public:
common::ObArenaAllocator rowkey_allocator_; // alloc buf for datum rowkey.
uint64_t tenant_id_;
@ -10583,6 +10583,7 @@ public:
share::ObSplitSSTableType split_sstable_type_;
ObSArray<uint64_t> lob_col_idxs_;
common::ObSArray<blocksstable::ObDatumRowkey> parallel_datum_rowkey_list_;
bool is_no_logging_;
};
struct ObDDLBuildSingleReplicaRequestResult final