[iotdb] branch InsertTabletNode updated (ccd0d96a08 -> 4481bf001e)

[ha...@apache.org]

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

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


    from ccd0d96a08 fix compile
     add 0296d2cf9d Fix -DskipTests cannot skip commons tests (#5422)
     add bc818999e0 Merge branch 'master' of https://github.com/apache/iotdb into InsertTabletNode
     add 26a762f40a [IOTDB-2846] Add Driver which implements ExecFragmentInstance interface (#5402)
     add 8f553e98c3 When a storage group is deleted, every related template will unmark it now. (#5380)
     add 4481bf001e Merge branch 'master' of https://github.com/apache/iotdb into InsertTabletNode

No new revisions were added by this update.

Summary of changes:
 node-commons/pom.xml                               |  12 +-
 .../storagegroup/VirtualStorageGroupProcessor.java |  31 ++
 .../iotdb/db/metadata/LocalConfigManager.java      |   4 +
 .../iotdb/db/metadata/template/Template.java       |   4 +
 .../db/metadata/template/TemplateManager.java      |   7 +
 .../StubSinkHandle.java}                           |  48 ++--
 .../apache/iotdb/db/mpp/execution/DataDriver.java  | 320 +++++++++++++++++++++
 .../iotdb/db/mpp/execution/DataDriverContext.java  |  62 ++++
 .../{ExecFragmentInstance.java => Driver.java}     |   6 +-
 .../iotdb/db/mpp/execution/DriverContext.java      |  30 +-
 .../db/mpp/execution/FragmentInstanceContext.java  |  56 +++-
 .../mpp/execution/FragmentInstanceExecution.java   |  88 ++++++
 ...StateMachine.java => FragmentInstanceInfo.java} |  24 +-
 .../db/mpp/execution/FragmentInstanceManager.java  | 181 ++++++++++++
 .../iotdb/db/mpp/execution/SchemaDriver.java       | 148 ++++++++++
 .../db/mpp/execution/SchemaDriverContext.java      |  18 +-
 .../org/apache/iotdb/db/mpp/operator/Operator.java |   6 +
 .../db/mpp/operator/process/AggregateOperator.java |   5 +
 .../mpp/operator/process/DeviceMergeOperator.java  |   5 +
 .../db/mpp/operator/process/FillOperator.java      |   5 +
 .../mpp/operator/process/FilterNullOperator.java   |   5 +
 .../mpp/operator/process/GroupByLevelOperator.java |   5 +
 .../db/mpp/operator/process/LimitOperator.java     |   5 +
 .../db/mpp/operator/process/OffsetOperator.java    |   5 +
 .../db/mpp/operator/process/SortOperator.java      |   5 +
 .../db/mpp/operator/process/TimeJoinOperator.java  |  24 +-
 .../db/mpp/operator/sink/FragmentSinkOperator.java |   5 +
 .../mpp/operator/source/AlignedSeriesScanUtil.java |   5 +-
 .../source/SeriesAggregateScanOperator.java        |   9 +
 .../db/mpp/operator/source/SeriesScanOperator.java |  22 +-
 .../db/mpp/operator/source/SeriesScanUtil.java     |  25 +-
 .../db/mpp/operator/source/SourceOperator.java     |   3 +
 ...Manager.java => FragmentInstanceScheduler.java} |  21 +-
 .../mpp/schedule/FragmentInstanceTaskExecutor.java |   6 +-
 ...anager.java => IFragmentInstanceScheduler.java} |  20 +-
 .../db/mpp/schedule/task/FragmentInstanceTask.java |  11 +-
 .../db/mpp/sql/planner/LocalExecutionPlanner.java  | 158 ++++++++--
 .../db/mpp/sql/planner/plan/FragmentInstance.java  |   7 +
 .../db/mpp/sql/planner/plan/node/PlanVisitor.java  |   5 +
 .../planner/plan/node/process/TimeJoinNode.java    |   8 +
 .../org/apache/iotdb/db/metadata/TemplateTest.java |  18 ++
 .../DataDriverTest.java}                           | 119 +++++---
 .../iotdb/db/mpp/operator/LimitOperatorTest.java   |  14 +-
 .../db/mpp/operator/SeriesScanOperatorTest.java    |  11 +-
 .../db/mpp/operator/TimeJoinOperatorTest.java      |  14 +-
 .../db/mpp/schedule/DefaultTaskSchedulerTest.java  |  73 ++---
 ...est.java => FragmentInstanceSchedulerTest.java} |  29 +-
 .../FragmentInstanceTimeoutSentinelTest.java       |  76 +++--
 48 files changed, 1504 insertions(+), 264 deletions(-)
 copy server/src/main/java/org/apache/iotdb/db/mpp/{operator/sink/FragmentSinkOperator.java => buffer/StubSinkHandle.java} (56%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriverContext.java
 rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ExecFragmentInstance.java => Driver.java} (90%)
 copy grafana-connector/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/DriverContext.java (57%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceExecution.java
 copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => FragmentInstanceInfo.java} (69%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceManager.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java
 copy consensus/src/main/java/org/apache/iotdb/consensus/exception/RatisRequestFailedException.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriverContext.java (66%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceManager.java => FragmentInstanceScheduler.java} (94%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/schedule/{IFragmentInstanceManager.java => IFragmentInstanceScheduler.java} (73%)
 copy server/src/test/java/org/apache/iotdb/db/mpp/{operator/LimitOperatorTest.java => execution/DataDriverTest.java} (57%)
 rename server/src/test/java/org/apache/iotdb/db/mpp/schedule/{FragmentInstanceManagerTest.java => FragmentInstanceSchedulerTest.java} (84%)