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

occupy for virtual_thread

Browse Source
This commit is contained in:
obdev 2023-11-09 14:16:58 +00:00 committed by ob-robot
parent 18cabc6bff
commit 2e3be94f99
5 changed files with 38 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/observer/virtual_table/ob_all_virtual_thread.cpp
View File

@ -218,6 +218,10 @@ int ObAllVirtualThread::inner_get_next_row(common::ObNewRow *&row)
cells[i].set_timestamp(loop_ts);
break;
}
case CGROUP_PATH: {
cells[i].set_varchar("");
break;
}
default: {
ret = OB_ERR_UNEXPECTED;
SERVER_LOG(WARN, "unexpected column id", K(col_id), K(i), K(ret));

3
src/observer/virtual_table/ob_all_virtual_thread.h
View File

@ -33,7 +33,8 @@ class ObAllVirtualThread : public common::ObVirtualTableScannerIterator
LATCH_WAIT,
LATCH_HOLD,
TRACE_ID,
LOOP_TS
LOOP_TS,
CGROUP_PATH
};
public:

15
src/share/inner_table/ob_inner_table_schema.12351_12400.cpp
View File

@ -6321,6 +6321,21 @@ int ObInnerTableSchema::all_virtual_thread_schema(ObTableSchema &table_schema)
false, //is_autoincrement
false); //is_on_update_for_timestamp
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("cgroup_path", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObVarcharType, //column_type
CS_TYPE_INVALID, //column_collation_type
256, //column_length
-1, //column_precision
-1, //column_scale
false, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
table_schema.get_part_option().set_part_num(1);
table_schema.set_part_level(PARTITION_LEVEL_ONE);

15
src/share/inner_table/ob_inner_table_schema.15251_15300.cpp
View File

@ -10873,6 +10873,21 @@ int ObInnerTableSchema::all_virtual_thread_ora_schema(ObTableSchema &table_schem
false, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
ADD_COLUMN_SCHEMA("CGROUP_PATH", //column_name
++column_id, //column_id
0, //rowkey_id
0, //index_id
0, //part_key_pos
ObVarcharType, //column_type
CS_TYPE_UTF8MB4_BIN, //column_collation_type
256, //column_length
2, //column_precision
-1, //column_scale
false, //is_nullable
false); //is_autoincrement
}
if (OB_SUCC(ret)) {
table_schema.get_part_option().set_part_num(1);
table_schema.set_part_level(PARTITION_LEVEL_ONE);

3
src/share/inner_table/ob_inner_table_schema_def.py
View File

@ -12767,7 +12767,8 @@ def_table_schema(
('latch_wait', 'varchar:16'),
('latch_hold', 'varchar:256'),
('trace_id', 'varchar:40'),
('loop_ts', 'timestamp')
('loop_ts', 'timestamp'),
('cgroup_path', 'varchar:256')
],
partition_columns = ['svr_ip', 'svr_port'],
vtable_route_policy = 'distributed',