This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch mpp-ty
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 562476e add comments for doneState in FragmentInstanceState
add 9ebaf3c define IScheduler interface, add two implemetation:
StandaloneScheduler and ClusterScheduler
add 226b140 format cde
No new revisions were added by this update.
Summary of changes:
.../node/PlanNode.java => common/FragmentId.java} | 38 +++++----
.../org/apache/iotdb/db/mpp/common/QueryId.java | 90 +++++++++++++++++++++-
.../TreeNode.java => execution/FragmentInfo.java} | 33 ++++----
.../iotdb/db/mpp/execution/FragmentState.java | 71 +++++++++++++++++
.../iotdb/db/mpp/execution/QueryExecution.java | 6 +-
.../ClusterScheduler.java} | 32 +++++++-
.../db/mpp/execution/scheduler/IScheduler.java | 29 ++++---
.../scheduler/StandaloneScheduler.java} | 43 +++++------
.../db/mpp/sql/planner/plan/FragmentInstance.java | 2 +
.../mpp/sql/planner/plan/FragmentInstanceId.java | 30 --------
10 files changed, 266 insertions(+), 108 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{sql/planner/plan/node/PlanNode.java
=> common/FragmentId.java} (53%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{common/TreeNode.java =>
execution/FragmentInfo.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentState.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryScheduler.java =>
scheduler/ClusterScheduler.java} (67%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/Rate.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IScheduler.java
(61%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{operator/sink/FragmentSinkOperator.java
=> execution/scheduler/StandaloneScheduler.java} (53%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/FragmentInstanceId.java
