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

assign some array memory in encoding module to tenant

Browse Source
This commit is contained in:
saltonz
2023-08-07 14:42:25 +00:00
committed by ob-robot
parent e24b2cefb7
commit f864205279
4 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/blocksstable/encoding/ob_inter_column_substring_encoder.cpp
View File

@ -33,6 +33,8 @@ ObInterColSubStrEncoder::ObInterColSubStrEncoder()
fix_data_size_(-1), start_pos_byte_(0), fix_data_size_(-1), start_pos_byte_(0),
val_len_byte_(0) val_len_byte_(0)
{ {
start_pos_array_.set_attr(ObMemAttr(MTL_ID(), "IntColSubStrEnc"));
exc_row_ids_.set_attr(ObMemAttr(MTL_ID(), "IntColSubStrEnc"));
} }
ObInterColSubStrEncoder::~ObInterColSubStrEncoder() ObInterColSubStrEncoder::~ObInterColSubStrEncoder()

11
src/storage/blocksstable/encoding/ob_micro_block_encoder.cpp
View File

@ -101,6 +101,16 @@ ObMicroBlockEncoder::ObMicroBlockEncoder() : ctx_(), header_(NULL),
string_col_cnt_(0), estimate_base_store_size_(0), length_(0), string_col_cnt_(0), estimate_base_store_size_(0), length_(0),
is_inited_(false) is_inited_(false)
{ {
datum_rows_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
all_col_datums_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
encoders_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
fix_data_encoders_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
var_data_encoders_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
row_indexs_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
hashtables_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
multi_prefix_trees_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
deep_copy_indexes_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
col_ctxs_.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
} }
ObMicroBlockEncoder::~ObMicroBlockEncoder() ObMicroBlockEncoder::~ObMicroBlockEncoder()
@ -781,6 +791,7 @@ int ObMicroBlockEncoder::fill_row_data(const int64_t fix_data_size)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObArray<int64_t> var_lengths; ObArray<int64_t> var_lengths;
var_lengths.set_attr(ObMemAttr(MTL_ID(), "MicroBlkEncoder"));
if (IS_NOT_INIT) { if (IS_NOT_INIT) {
ret = OB_NOT_INIT; ret = OB_NOT_INIT;
LOG_WARN("not init", K(ret)); LOG_WARN("not init", K(ret));

1
src/storage/blocksstable/encoding/ob_string_diff_encoder.cpp
View File

@ -34,6 +34,7 @@ ObStringDiffEncoder::ObStringDiffEncoder()
header_(NULL), last_change_diff_row_id_(0), header_(NULL), last_change_diff_row_id_(0),
allocator_(blocksstable::OB_ENCODING_LABEL_STRING_DIFF, OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID()) allocator_(blocksstable::OB_ENCODING_LABEL_STRING_DIFF, OB_MALLOC_NORMAL_BLOCK_SIZE, MTL_ID())
{ {
diff_descs_.set_attr(ObMemAttr(MTL_ID(), "StrDiffEnc"));
} }
int ObStringDiffEncoder::init( int ObStringDiffEncoder::init(

1
src/storage/blocksstable/ob_block_sstable_struct.h
View File

@ -547,6 +547,7 @@ struct ObMicroBlockEncodingCtx
column_encodings_(nullptr), major_working_cluster_version_(0), column_encodings_(nullptr), major_working_cluster_version_(0),
row_store_type_(ENCODING_ROW_STORE), need_calc_column_chksum_(false) row_store_type_(ENCODING_ROW_STORE), need_calc_column_chksum_(false)
{ {
previous_encodings_.set_attr(ObMemAttr(MTL_ID(), "MicroEncodeCtx"));
} }
bool is_valid() const; bool is_valid() const;
TO_STRING_KV(K_(macro_block_size), K_(micro_block_size), K_(rowkey_column_cnt), TO_STRING_KV(K_(macro_block_size), K_(micro_block_size), K_(rowkey_column_cnt),