[4.4] add required_size for __all_virtual_ls_info
This commit is contained in:
@ -197,6 +197,10 @@ int ObAllVirtualLSInfo::process_curr_tenant(ObNewRow *&row)
|
|||||||
// tx blocked
|
// tx blocked
|
||||||
cur_row_.cells_[i].set_int(ls_info.tx_blocked_);
|
cur_row_.cells_[i].set_int(ls_info.tx_blocked_);
|
||||||
break;
|
break;
|
||||||
|
case OB_APP_MIN_COLUMN_ID + 16:
|
||||||
|
// required_size
|
||||||
|
cur_row_.cells_[i].set_int(0);
|
||||||
|
break;
|
||||||
default:
|
default:
|
||||||
ret = OB_ERR_UNEXPECTED;
|
ret = OB_ERR_UNEXPECTED;
|
||||||
SERVER_LOG(WARN, "invalid col_id", K(ret), K(col_id));
|
SERVER_LOG(WARN, "invalid col_id", K(ret), K(col_id));
|
||||||
|
|||||||
@ -9827,6 +9827,25 @@ int ObInnerTableSchema::all_virtual_ls_info_schema(ObTableSchema &table_schema)
|
|||||||
false, //is_nullable
|
false, //is_nullable
|
||||||
false); //is_autoincrement
|
false); //is_autoincrement
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ObObj required_size_default;
|
||||||
|
required_size_default.set_int(0);
|
||||||
|
ADD_COLUMN_SCHEMA_T("required_size", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObIntType, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
sizeof(int64_t), //column_length
|
||||||
|
-1, //column_precision
|
||||||
|
-1, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false, //is_autoincrement
|
||||||
|
required_size_default,
|
||||||
|
required_size_default); //default_value
|
||||||
|
}
|
||||||
if (OB_SUCC(ret)) {
|
if (OB_SUCC(ret)) {
|
||||||
table_schema.get_part_option().set_part_num(1);
|
table_schema.get_part_option().set_part_num(1);
|
||||||
table_schema.set_part_level(PARTITION_LEVEL_ONE);
|
table_schema.set_part_level(PARTITION_LEVEL_ONE);
|
||||||
|
|||||||
@ -5082,6 +5082,21 @@ int ObInnerTableSchema::all_virtual_ls_info_ora_schema(ObTableSchema &table_sche
|
|||||||
false, //is_nullable
|
false, //is_nullable
|
||||||
false); //is_autoincrement
|
false); //is_autoincrement
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (OB_SUCC(ret)) {
|
||||||
|
ADD_COLUMN_SCHEMA("REQUIRED_SIZE", //column_name
|
||||||
|
++column_id, //column_id
|
||||||
|
0, //rowkey_id
|
||||||
|
0, //index_id
|
||||||
|
0, //part_key_pos
|
||||||
|
ObNumberType, //column_type
|
||||||
|
CS_TYPE_INVALID, //column_collation_type
|
||||||
|
38, //column_length
|
||||||
|
38, //column_precision
|
||||||
|
0, //column_scale
|
||||||
|
false, //is_nullable
|
||||||
|
false); //is_autoincrement
|
||||||
|
}
|
||||||
if (OB_SUCC(ret)) {
|
if (OB_SUCC(ret)) {
|
||||||
table_schema.get_part_option().set_part_num(1);
|
table_schema.get_part_option().set_part_num(1);
|
||||||
table_schema.set_part_level(PARTITION_LEVEL_ONE);
|
table_schema.set_part_level(PARTITION_LEVEL_ONE);
|
||||||
|
|||||||
@ -12341,6 +12341,7 @@ def_table_schema(
|
|||||||
('tablet_change_checkpoint_scn', 'uint'),
|
('tablet_change_checkpoint_scn', 'uint'),
|
||||||
('transfer_scn', 'uint'),
|
('transfer_scn', 'uint'),
|
||||||
('tx_blocked', 'int'),
|
('tx_blocked', 'int'),
|
||||||
|
('required_size', 'int', 'false', 0),
|
||||||
],
|
],
|
||||||
partition_columns = ['svr_ip', 'svr_port'],
|
partition_columns = ['svr_ip', 'svr_port'],
|
||||||
vtable_route_policy = 'distributed',
|
vtable_route_policy = 'distributed',
|
||||||
|
|||||||
@ -2879,6 +2879,7 @@ rebuild_seq bigint(20) NO NULL
|
|||||||
tablet_change_checkpoint_scn bigint(20) unsigned NO NULL
|
tablet_change_checkpoint_scn bigint(20) unsigned NO NULL
|
||||||
transfer_scn bigint(20) unsigned NO NULL
|
transfer_scn bigint(20) unsigned NO NULL
|
||||||
tx_blocked bigint(20) NO NULL
|
tx_blocked bigint(20) NO NULL
|
||||||
|
required_size bigint(20) NO 0
|
||||||
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_ls_info;
|
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_ls_info;
|
||||||
IF(count(*) >= 0, 1, 0)
|
IF(count(*) >= 0, 1, 0)
|
||||||
1
|
1
|
||||||
|
|||||||
@ -6462,6 +6462,7 @@ rebuild_seq bigint(20) NO NULL
|
|||||||
tablet_change_checkpoint_scn bigint(20) unsigned NO NULL
|
tablet_change_checkpoint_scn bigint(20) unsigned NO NULL
|
||||||
transfer_scn bigint(20) unsigned NO NULL
|
transfer_scn bigint(20) unsigned NO NULL
|
||||||
tx_blocked bigint(20) NO NULL
|
tx_blocked bigint(20) NO NULL
|
||||||
|
required_size bigint(20) NO 0
|
||||||
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_ls_info;
|
select /*+QUERY_TIMEOUT(60000000)*/ IF(count(*) >= 0, 1, 0) from oceanbase.__all_virtual_ls_info;
|
||||||
IF(count(*) >= 0, 1, 0)
|
IF(count(*) >= 0, 1, 0)
|
||||||
1
|
1
|
||||||
|
|||||||
Reference in New Issue
Block a user