This is an automated email from the ASF dual-hosted git repository.
adonisling pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 0e70d681d9 [feature](Nereids): Construct join graph (#13679)
add ec86e9c9b2 [feature-wip][MTMV] The schedule framework for the MTMV
(#13147)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/catalog/Env.java | 29 ++
.../main/java/org/apache/doris/common/Config.java | 15 +
.../apache/doris/datasource/InternalCatalog.java | 15 +
.../org/apache/doris/journal/JournalEntity.java | 30 ++
.../java/org/apache/doris/mtmv/MTMVJobFactory.java | 37 ++
.../java/org/apache/doris/mtmv/MTMVJobManager.java | 421 ++++++++++++++++++++
.../org/apache/doris/mtmv/MTMVTaskContext.java | 61 +++
.../apache/doris/mtmv/MTMVTaskExecuteParams.java | 36 ++
.../org/apache/doris/mtmv/MTMVTaskExecutor.java | 179 +++++++++
.../apache/doris/mtmv/MTMVTaskExecutorPool.java | 76 ++++
.../org/apache/doris/mtmv/MTMVTaskManager.java | 432 +++++++++++++++++++++
.../org/apache/doris/mtmv/MTMVTaskProcessor.java | 29 ++
.../main/java/org/apache/doris/mtmv/MTMVUtils.java | 114 ++++++
.../apache/doris/mtmv/metadata/AlterMTMVTask.java | 133 +++++++
.../apache/doris/mtmv/metadata/ChangeMTMVJob.java | 98 +++++
.../apache/doris/mtmv/metadata/DropMTMVJob.java | 52 +++
.../apache/doris/mtmv/metadata/DropMTMVTask.java | 53 +++
.../doris/mtmv/metadata/MTMVCheckpointData.java | 48 +++
.../org/apache/doris/mtmv/metadata/MTMVJob.java | 251 ++++++++++++
.../org/apache/doris/mtmv/metadata/MTMVTask.java | 187 +++++++++
.../java/org/apache/doris/persist/EditLog.java | 60 +++
.../org/apache/doris/persist/OperationType.java | 9 +
.../doris/persist/meta/MetaPersistMethod.java | 6 +
.../doris/persist/meta/PersistMetaModules.java | 2 +-
.../org/apache/doris/mtmv/MTMVJobManagerTest.java | 79 ++++
.../apache/doris/mtmv/MTMVTaskExecutorTest.java | 104 +++++
.../java/org/apache/doris/mtmv/MTMVUtilsTest.java | 89 +++++
27 files changed, 2644 insertions(+), 1 deletion(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobFactory.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVJobManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskContext.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskExecuteParams.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskExecutor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskExecutorPool.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskManager.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVTaskProcessor.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVUtils.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/AlterMTMVTask.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/ChangeMTMVJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/DropMTMVJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/DropMTMVTask.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/MTMVCheckpointData.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/MTMVJob.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/mtmv/metadata/MTMVTask.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVJobManagerTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVTaskExecutorTest.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/mtmv/MTMVUtilsTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
