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

Micro Compaction Part 1 : master placeholder 2

Browse Source
This commit is contained in:
KyrielightWei 2024-10-12 05:58:58 +00:00 committed by ob-robot
parent 99abe0b97e
commit acc0e6d5da
5 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/share/resource_manager/ob_resource_manager_proxy.cpp
View File

@ -732,7 +732,8 @@ int ObResourceManagerProxy::check_if_function_exist(const ObString &function_nam
0 == function_name.compare("IMPORT") || 0 == function_name.compare("IMPORT") ||
0 == function_name.compare("EXPORT") || 0 == function_name.compare("EXPORT") ||
0 == function_name.compare("SQL_AUDIT") || 0 == function_name.compare("SQL_AUDIT") ||
0 == function_name.compare("GC_MACRO_BLOCK")) { 0 == function_name.compare("GC_MACRO_BLOCK") ||
0 == function_name.compare("MICRO_MINI_MERGE")) {
exist = true; exist = true;
} else { } else {
exist = false; exist = false;

3
src/share/resource_manager/ob_resource_plan_info.cpp
View File

@ -71,6 +71,9 @@ ObString oceanbase::share::get_io_function_name(ObFunctionType function_type)
case ObFunctionType::PRIO_SQL_AUDIT: case ObFunctionType::PRIO_SQL_AUDIT:
ret_name = ObString("SQL_AUDIT"); ret_name = ObString("SQL_AUDIT");
break; break;
case ObFunctionType::PRIO_MICRO_MINI_MERGE:
ret_name = ObString("MICRO_MINI_MERGE");
break;
default: default:
ret_name = ObString("OTHER_GROUPS"); ret_name = ObString("OTHER_GROUPS");
break; break;

1
src/share/resource_manager/ob_resource_plan_info.h
View File

@ -47,6 +47,7 @@ enum ObFunctionType : uint8_t
/* add new function type here, or you will have compatibility issues. */ /* add new function type here, or you will have compatibility issues. */
PRIO_SQL_AUDIT = 16, PRIO_SQL_AUDIT = 16,
PRIO_MICRO_MINI_MERGE = 17,
/* add new function, can learn by "grep -rnI 'CLOG_HIGH' src/" */ /* add new function, can learn by "grep -rnI 'CLOG_HIGH' src/" */
MAX_FUNCTION_NUM MAX_FUNCTION_NUM

3
src/share/scheduler/ob_sys_task_stat.cpp
View File

@ -43,7 +43,8 @@ const static char *ObSysTaskTypeStr[] = {
"TENANT_SNAPSHOT_GC", "TENANT_SNAPSHOT_GC",
"BATCH_FREEZE_TABLET_TASK", "BATCH_FREEZE_TABLET_TASK",
"VECTOR_INDEX_TASK", "VECTOR_INDEX_TASK",
"DDL_TABLET_SPLIT" "DDL_TABLET_SPLIT",
"SSTABLE_MICRO_MINI_MERGE"
}; };
const char *sys_task_type_to_str(const ObSysTaskType &type) const char *sys_task_type_to_str(const ObSysTaskType &type)

1
src/share/scheduler/ob_sys_task_stat.h
View File

@ -57,6 +57,7 @@ enum ObSysTaskType
BATCH_FREEZE_TABLET_TASK, BATCH_FREEZE_TABLET_TASK,
VECTOR_INDEX_TASK, VECTOR_INDEX_TASK,
DDL_TABLET_SPLIT, DDL_TABLET_SPLIT,
SSTABLE_MICRO_MINI_MERGE_TASK,
MAX_SYS_TASK_TYPE MAX_SYS_TASK_TYPE
}; };