database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[refactor](executor)Rename workload schedule policy #34497

Browse Source
This commit is contained in:
wangbo
2024-05-08 08:34:31 +08:00
committed by yiguolei
parent dec5f0ca98
commit 39fdc9ba0c
12 changed files with 66 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/analysis/SchemaTableType.java
View File

@ -76,8 +76,8 @@ public enum SchemaTableType {
SCHE_USER("user", "user", TSchemaTableType.SCH_USER),
SCH_PROCS_PRIV("procs_priv", "procs_priv", TSchemaTableType.SCH_PROCS_PRIV),
SCH_WORKLOAD_SCHEDULE_POLICY("WORKLOAD_SCHEDULE_POLICY", "WORKLOAD_SCHEDULE_POLICY",
TSchemaTableType.SCH_WORKLOAD_SCHEDULE_POLICY);
SCH_WORKLOAD_POLICY("WORKLOAD_POLICY", "WORKLOAD_POLICY",
TSchemaTableType.SCH_WORKLOAD_POLICY);
private static final String dbName = "INFORMATION_SCHEMA";
private static SelectList fullSelectLists;

4
fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
View File

@ -499,8 +499,8 @@ public class SchemaTable extends Table {
.column("STATE", ScalarType.createVarchar(64))
.column("INFO", ScalarType.createVarchar(ScalarType.MAX_VARCHAR_LENGTH))
.build()))
.put("workload_schedule_policy",
new SchemaTable(SystemIdGenerator.getNextId(), "workload_schedule_policy", TableType.SCHEMA,
.put("workload_policy",
new SchemaTable(SystemIdGenerator.getNextId(), "workload_policy", TableType.SCHEMA,
builder().column("ID", ScalarType.createType(PrimitiveType.BIGINT))
.column("NAME", ScalarType.createVarchar(256))
.column("CONDITION", ScalarType.createStringType())

2
fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java
View File

@ -121,7 +121,7 @@ public class MetadataGenerator {
ROUTINE_INFO_COLUMN_TO_INDEX = routineInfoBuilder.build();
ImmutableMap.Builder<String, Integer> policyBuilder = new ImmutableMap.Builder();
List<Column> policyColList = SchemaTable.TABLE_MAP.get("workload_schedule_policy").getFullSchema();
List<Column> policyColList = SchemaTable.TABLE_MAP.get("workload_policy").getFullSchema();
for (int i = 0; i < policyColList.size(); i++) {
policyBuilder.put(policyColList.get(i).getName().toLowerCase(), i);
}