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 49938f4 [IOTDB-2772] Fix influxdb build error (#5292)
add 537069e [IoTDB-2660] Implement the basic functionalities for
DistributionPlanner (#5291)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/mpp/common/Analysis.java | 42 +++-
.../org/apache/iotdb/db/mpp/common/DataRegion.java | 53 +++--
.../iotdb/db/mpp/common/DataRegionTimeSlice.java | 12 +-
.../iotdb/db/mpp/common/FilterNullPolicy.java | 1 +
.../{QueryContext.java => MPPQueryContext.java} | 2 +-
.../org/apache/iotdb/db/mpp/common/OrderBy.java | 27 ---
.../apache/iotdb/db/mpp/common/SchemaRegion.java | 16 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 6 +-
.../iotdb/db/mpp/operator/sink/SinkOperator.java | 2 +-
.../sql/planner/optimization/PlanOptimizer.java | 4 +-
.../mpp/sql/planner/plan/DistributedQueryPlan.java | 4 +-
.../mpp/sql/planner/plan/DistributionPlanner.java | 219 +++++++++++++++++++++
.../db/mpp/sql/planner/plan/LogicalPlanner.java | 7 +-
.../db/mpp/sql/planner/plan/LogicalQueryPlan.java | 17 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 4 +
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 11 ++
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 13 +-
.../sql/planner/plan/node/PlanNodeUtil.java} | 21 +-
...ftSinkNode.java => SimplePlanNodeRewriter.java} | 34 ++--
.../planner/plan/node/process/AggregateNode.java | 10 +
.../planner/plan/node/process/DeviceMergeNode.java | 12 +-
.../process/{FilterNode.java => ExchangeNode.java} | 57 +++---
.../sql/planner/plan/node/process/FillNode.java | 10 +
.../sql/planner/plan/node/process/FilterNode.java | 10 +
.../planner/plan/node/process/FilterNullNode.java | 10 +
.../plan/node/process/GroupByLevelNode.java | 10 +
.../sql/planner/plan/node/process/LimitNode.java | 31 ++-
.../sql/planner/plan/node/process/OffsetNode.java | 12 +-
.../sql/planner/plan/node/process/SortNode.java | 12 +-
.../planner/plan/node/process/TimeJoinNode.java | 32 ++-
.../sql/planner/plan/node/sink/CsvSinkNode.java | 10 +
.../planner/plan/node/sink/FragmentSinkNode.java | 10 +
.../sql/planner/plan/node/sink/ThriftSinkNode.java | 10 +
.../planner/plan/node/source/CsvSourceNode.java | 10 +
.../plan/node/source/SeriesAggregateScanNode.java | 18 ++
.../planner/plan/node/source/SeriesScanNode.java | 43 +++-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 127 ++++++++++++
37 files changed, 781 insertions(+), 148 deletions(-)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java =>
server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegion.java (52%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegionTimeSlice.java
(80%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/{QueryContext.java
=> MPPQueryContext.java} (97%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/OrderBy.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/NoHeaderNodeException.java
=> server/src/main/java/org/apache/iotdb/db/mpp/common/SchemaRegion.java (70%)
copy
server/src/main/java/org/apache/iotdb/db/{auth/user/LocalFileUserManager.java
=> mpp/sql/planner/plan/node/PlanNodeUtil.java} (63%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/{sink/ThriftSinkNode.java
=> SimplePlanNodeRewriter.java} (56%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/{FilterNode.java
=> ExchangeNode.java} (54%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java
