This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch new_mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from a95558e [IOTDB-2673] Implement the consensus layer basic framework
(#5204)
add 37f6f70 Basic implementation of FragmentInstanceManager
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/service/ServiceType.java | 3 +-
.../iotdb/mpp/execution/ExecutionContext.java | 9 +-
.../mpp/execution/FragmentInstanceManager.java | 101 ++++++++++++++
.../execution/FragmentInstanceTaskExecutor.java} | 37 +++---
.../FragmentInstanceTimeoutSentinel.java} | 29 +++-
.../mpp/execution/IFragmentInstanceManager.java | 50 +++++++
.../org/apache/iotdb/mpp/execution/queue/ID.java | 6 +-
.../mpp/execution/queue/IDIndexedAccessible.java | 10 +-
.../mpp/execution/queue/IndexedBlockingQueue.java | 148 +++++++++++++++++++++
.../iotdb/mpp/execution/queue/L1PriorityQueue.java | 76 +++++++++++
.../iotdb/mpp/execution/queue/L2PriorityQueue.java | 89 +++++++++++++
.../mpp/execution/task/FragmentInstanceID.java | 67 ++++++++++
.../mpp/execution/task/FragmentInstanceTask.java | 138 +++++++++++++++++++
.../task/FragmentInstanceTaskStatus.java} | 24 ++--
14 files changed, 740 insertions(+), 47 deletions(-)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/member/DataGroupMemberMBean.java
=> server/src/main/java/org/apache/iotdb/mpp/execution/ExecutionContext.java
(80%)
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/FragmentInstanceManager.java
copy
server/src/main/java/org/apache/iotdb/{db/qp/logical/crud/FunctionOperator.java
=> mpp/execution/FragmentInstanceTaskExecutor.java} (54%)
copy
server/src/main/java/org/apache/iotdb/{db/concurrent/IoTDBDefaultThreadExceptionHandler.java
=> mpp/execution/FragmentInstanceTimeoutSentinel.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/IFragmentInstanceManager.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java
=> server/src/main/java/org/apache/iotdb/mpp/execution/queue/ID.java (87%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java
=>
server/src/main/java/org/apache/iotdb/mpp/execution/queue/IDIndexedAccessible.java
(82%)
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/queue/IndexedBlockingQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/queue/L1PriorityQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/queue/L2PriorityQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/task/FragmentInstanceID.java
create mode 100644
server/src/main/java/org/apache/iotdb/mpp/execution/task/FragmentInstanceTask.java
copy
server/src/main/java/org/apache/iotdb/{db/engine/compaction/cross/rewrite/selector/ICrossSpaceMergeFileSelector.java
=> mpp/execution/task/FragmentInstanceTaskStatus.java} (64%)
