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

[CP] [LOB] support inrow threshold config

Browse Source
This commit is contained in:
shadowao
2023-12-11 05:17:14 +00:00
committed by ob-robot
parent 820c5f4e6d
commit 2af60a0292
22 changed files with 234 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/ddl/ob_complement_data_task.cpp
View File

@ -1163,6 +1163,7 @@ int ObComplementWriteTask::append_row(ObScan *scan)
const int64_t extra_rowkey_cnt = storage::ObMultiVersionRowkeyHelpper::get_extra_rowkey_col_cnt();
bool ddl_committed = false;
blocksstable::ObNewRowBuilder new_row_builder;
int64_t lob_inrow_threshold = OB_DEFAULT_LOB_INROW_THRESHOLD;
if (OB_UNLIKELY(!is_inited_)) {
ret = OB_NOT_INIT;
LOG_WARN("ObComplementWriteTask is not inited", K(ret));
@ -1208,6 +1209,7 @@ int ObComplementWriteTask::append_row(ObScan *scan)
LOG_WARN("fail to open macro block writer", K(ret), K(data_desc));
} else {
rowkey_column_cnt = hidden_table_schema->get_rowkey_column_num();
lob_inrow_threshold = hidden_table_schema->get_lob_inrow_threshold();
}
ObTableSchemaParam schema_param(allocator);
// Hack to prevent row reshaping from converting empty string to null.
@ -1261,9 +1263,11 @@ int ObComplementWriteTask::append_row(ObScan *scan)
} else if (org_col_ids_.at(i).col_type_.is_lob_storage()) {
lob_cnt++;
const int64_t timeout_ts = ObTimeUtility::current_time() + 60000000; // 60s
ObLobStorageParam lob_storage_param;
lob_storage_param.inrow_threshold_ = lob_inrow_threshold;
if (OB_FAIL(ObInsertLobColumnHelper::insert_lob_column(
lob_allocator, param_->dest_ls_id_, param_->dest_tablet_id_,
org_col_ids_.at(i), datum, timeout_ts, true, param_->orig_tenant_id_))) {
org_col_ids_.at(i), lob_storage_param, datum, timeout_ts, true, param_->orig_tenant_id_))) {
LOG_WARN("fail to insert_lob_col", K(ret), K(datum));
}
}