[iotdb] branch master updated (d3aa3c1 -> e15c65f)

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


    from d3aa3c1  [IOTDB-2775] Fix throwing exception when query non-exist device in TsFileSequenceReader
     add e15c65f  [IOTDB-2726][IOTDB-2727] Basic interfaces definition of mpp scheduling and memory control (#5294)

No new revisions were added by this update.

Summary of changes:
 .../iotdb/commons/concurrent/ThreadName.java       |   6 +-
 .../apache/iotdb/commons/service/ServiceType.java  |   4 +-
 .../iotdb/db/mpp/buffer/DataBlockManager.java      | 116 ++++++++
 .../buffer/DataBlockManagerService.java}           |  62 ++---
 .../DataBlockManagerServiceThriftHandler.java      |  11 +-
 .../mpp/buffer/DataBlockServiceClientFactory.java  |  44 ++++
 .../iotdb/db/mpp/buffer/DataBlockServiceImpl.java  |  52 ++--
 .../buffer/{SinkHandle.java => ISinkHandle.java}   |  35 +--
 .../{SourceHandle.java => ISourceHandle.java}      |  11 +-
 .../apache/iotdb/db/mpp/buffer/SourceHandle.java   |  70 ++++-
 .../iotdb/db/mpp/memory/LocalMemoryManager.java    |  32 +--
 .../org/apache/iotdb/db/mpp/memory/MemoryPool.java |  93 +++++++
 .../iotdb/db/mpp/schedule/AbstractExecutor.java    |  72 +++++
 .../iotdb/db/mpp/schedule/ExecutionContext.java    |  37 ++-
 .../db/mpp/schedule/FragmentInstanceManager.java   | 292 +++++++++++++++++++++
 .../mpp/schedule/FragmentInstanceTaskExecutor.java |  84 ++++++
 .../schedule/FragmentInstanceTimeoutSentinel.java  |  55 ++++
 .../db/mpp/schedule/IFragmentInstanceManager.java  |  29 +-
 .../iotdb/db/mpp/schedule/ITaskScheduler.java      |  77 ++++++
 .../org/apache/iotdb/db/mpp/schedule/queue/ID.java |   6 +-
 .../schedule/queue/IDIndexedAccessible.java}       |  39 +--
 .../mpp/schedule/queue/IndexedBlockingQueue.java   | 188 +++++++++++++
 .../db/mpp/schedule/queue/L1PriorityQueue.java     |  86 ++++++
 .../db/mpp/schedule/queue/L2PriorityQueue.java     | 103 ++++++++
 .../db/mpp/schedule/task/FragmentInstanceID.java   |  68 +++++
 .../db/mpp/schedule/task/FragmentInstanceTask.java | 199 ++++++++++++++
 .../schedule/task/FragmentInstanceTaskStatus.java} |  24 +-
 .../org/apache/iotdb/db/utils/stats/CpuTimer.java  | 156 +++++++++++
 .../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 150 +++++++++++
 .../db/mpp/schedule/queue/L1PriorityQueueTest.java | 134 ++++++++++
 .../db/mpp/schedule/queue/L2PriorityQueueTest.java | 143 ++++++++++
 .../iotdb/db/mpp/schedule/queue/QueueElement.java  |  80 ++++++
 .../src/main/thrift/mpp.thrift                     |  50 ++--
 33 files changed, 2402 insertions(+), 206 deletions(-)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManager.java
 copy server/src/main/java/org/apache/iotdb/db/{service/InfluxDBRPCService.java => mpp/buffer/DataBlockManagerService.java} (51%)
 copy cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java => server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManagerServiceThriftHandler.java (75%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceClientFactory.java
 copy tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TestTsFileOutput.java => server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceImpl.java (50%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/buffer/{SinkHandle.java => ISinkHandle.java} (53%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/buffer/{SourceHandle.java => ISourceHandle.java} (72%)
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/TsFileRuntimeException.java => server/src/main/java/org/apache/iotdb/db/mpp/memory/LocalMemoryManager.java (55%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/memory/MemoryPool.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/AbstractExecutor.java
 copy tsfile/src/main/java/org/apache/iotdb/tsfile/common/constant/TsFileConstant.java => server/src/main/java/org/apache/iotdb/db/mpp/schedule/ExecutionContext.java (57%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceManager.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceTaskExecutor.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceTimeoutSentinel.java
 copy cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/SlotBalancer.java => server/src/main/java/org/apache/iotdb/db/mpp/schedule/IFragmentInstanceManager.java (52%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/ITaskScheduler.java
 copy cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java => server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/ID.java (87%)
 copy server/src/main/java/org/apache/iotdb/db/{qp/physical/crud/UDFPlan.java => mpp/schedule/queue/IDIndexedAccessible.java} (54%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/IndexedBlockingQueue.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/L1PriorityQueue.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/L2PriorityQueue.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/FragmentInstanceID.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/FragmentInstanceTask.java
 copy server/src/main/java/org/apache/iotdb/db/{engine/compaction/cross/rewrite/selector/ICrossSpaceMergeFileSelector.java => mpp/schedule/task/FragmentInstanceTaskStatus.java} (64%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/stats/CpuTimer.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/memory/MemoryPoolTest.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/queue/L1PriorityQueueTest.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/queue/L2PriorityQueueTest.java
 create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/queue/QueueElement.java
 copy cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMemberMBean.java => thrift/src/main/thrift/mpp.thrift (50%)