You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by er...@apache.org on 2022/03/14 10:11:22 UTC
[iotdb] branch new_mpp updated (a95558e -> 37f6f70)

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%)