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 b017eae [IOTDB-2784] Add unit tests for FragmentInstanceTask
scheduling (#5337)
add 4050490 Connect the Query Plan stage from SQL to DistributionPlan
with UT and mock interfaces (#5364)
No new revisions were added by this update.
Summary of changes:
.../commons/partition/DataRegionReplicaSet.java | 8 ++
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 37 +++++++
.../iotdb/db/mpp/execution/QueryExecution.java | 18 +++-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 4 +-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 107 +++++++++++++++++++++
...hemaFetcher.java => FakeSchemaFetcherImpl.java} | 8 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 18 ++--
.../db/mpp/sql/planner/plan/FragmentInstance.java | 1 -
.../db/mpp/sql/planner/plan/PlanFragment.java | 2 +-
.../plan/SimpleFragmentParallelPlanner.java | 3 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 30 +++++-
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 52 +++++++++-
.../plan/node/metedata/read/ShowDevicesNode.java | 9 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 9 +-
.../write/CreateAlignedTimeSeriesNode.java | 9 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 9 +-
.../planner/plan/node/process/AggregateNode.java | 11 ++-
.../planner/plan/node/process/DeviceMergeNode.java | 20 +++-
.../planner/plan/node/process/ExchangeNode.java | 22 ++---
.../sql/planner/plan/node/process/FillNode.java | 15 ++-
.../sql/planner/plan/node/process/FilterNode.java | 20 ++--
.../planner/plan/node/process/FilterNullNode.java | 18 ++--
.../plan/node/process/GroupByLevelNode.java | 11 ++-
.../sql/planner/plan/node/process/LimitNode.java | 10 +-
.../sql/planner/plan/node/process/OffsetNode.java | 20 ++--
.../sql/planner/plan/node/process/SortNode.java | 20 ++--
.../planner/plan/node/process/TimeJoinNode.java | 10 +-
.../sql/planner/plan/node/sink/CsvSinkNode.java | 67 -------------
.../planner/plan/node/sink/FragmentSinkNode.java | 13 ++-
.../sql/planner/plan/node/sink/ThriftSinkNode.java | 69 -------------
.../planner/plan/node/source/CsvSourceNode.java | 90 -----------------
.../plan/node/source/SeriesAggregateScanNode.java | 9 +-
.../planner/plan/node/source/SeriesScanNode.java | 6 +-
.../plan/node/write/InsertMultiTabletNode.java | 9 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 9 +-
.../planner/plan/node/write/InsertRowsNode.java | 9 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +-
.../planner/plan/node/write/InsertTabletNode.java | 9 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 25 ++++-
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 61 ++++++++++++
40 files changed, 514 insertions(+), 372 deletions(-)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/FakePartitionFetcherImpl.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/{ClusterSchemaFetcher.java
=> FakeSchemaFetcherImpl.java} (87%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/CsvSinkNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/ThriftSinkNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/CsvSourceNode.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
