This is an automated email from the ASF dual-hosted git repository.
wangbo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from c72191eb9ef [refactor](profile&names) using dst_id in pipelinex
profile to be same as non pipeline; rename some function names (#28626)
add 71b7dcfb8fd [feature][executor]support workload schedule policy
(#28443)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/common/Config.java | 6 +
fe/fe-core/src/main/cup/sql_parser.cup | 164 ++++++-
.../analysis/AlterWorkloadSchedPolicyStmt.java | 71 +++
.../analysis/CreateWorkloadSchedPolicyStmt.java | 91 ++++
.../analysis/DropWorkloadSchedPolicyStmt.java | 66 +++
.../analysis/ShowWorkloadSchedPolicyStmt.java | 59 +++
.../main/java/org/apache/doris/catalog/Env.java | 25 +
.../java/org/apache/doris/common/FeNameFormat.java | 4 +
.../publish/WorkloadActionPublishThread.java | 123 +++++
.../org/apache/doris/journal/JournalEntity.java | 13 +
.../DropWorkloadSchedPolicyOperatorLog.java | 51 ++
.../java/org/apache/doris/persist/EditLog.java | 29 ++
.../org/apache/doris/persist/OperationType.java | 3 +
.../doris/persist/meta/MetaPersistMethod.java | 7 +
.../doris/persist/meta/PersistMetaModules.java | 2 +-
.../java/org/apache/doris/qe/ConnectContext.java | 2 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 4 +
.../main/java/org/apache/doris/qe/DdlExecutor.java | 9 +
.../java/org/apache/doris/qe/ShowExecutor.java | 9 +
.../resource/workloadgroup/WorkloadGroupMgr.java | 13 +
.../workloadschedpolicy/WorkloadAction.java | 41 ++
.../WorkloadActionCancelQuery.java | 47 ++
.../workloadschedpolicy/WorkloadActionMeta.java | 47 ++
.../WorkloadActionMoveQueryToGroup.java | 67 +++
.../WorkloadActionSetSessionVar.java | 75 +++
.../workloadschedpolicy/WorkloadActionType.java | 24 +
.../workloadschedpolicy/WorkloadCondition.java | 40 ++
.../WorkloadConditionCompareUtils.java | 85 ++++
.../workloadschedpolicy/WorkloadConditionMeta.java | 54 +++
.../WorkloadConditionOperator.java | 22 +
.../WorkloadConditionQueryTime.java | 52 ++
.../WorkloadConditionUsername.java | 48 ++
.../workloadschedpolicy/WorkloadMetricType.java | 22 +
.../workloadschedpolicy/WorkloadQueryInfo.java | 30 ++
.../workloadschedpolicy/WorkloadSchedPolicy.java | 203 ++++++++
.../WorkloadSchedPolicyMgr.java | 535 +++++++++++++++++++++
fe/fe-core/src/main/jflex/sql_scanner.flex | 3 +
gensrc/thrift/BackendService.thrift | 7 +
38 files changed, 2150 insertions(+), 3 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/AlterWorkloadSchedPolicyStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateWorkloadSchedPolicyStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/DropWorkloadSchedPolicyStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowWorkloadSchedPolicyStmt.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/common/publish/WorkloadActionPublishThread.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/persist/DropWorkloadSchedPolicyOperatorLog.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadAction.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadActionCancelQuery.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadActionMeta.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadActionMoveQueryToGroup.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadActionSetSessionVar.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadActionType.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadCondition.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadConditionCompareUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadConditionMeta.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadConditionOperator.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadConditionQueryTime.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadConditionUsername.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadMetricType.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadQueryInfo.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadSchedPolicy.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/resource/workloadschedpolicy/WorkloadSchedPolicyMgr.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
