This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch lmh/PredicatePushDown
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 40372fffc0d optimize for templated info + align by device query with
value filter
add f35b2a5306e Fix it which use 'merge' command (#12060)
add 4ca47c7c539 Pipe: Fixed the bug that CN cannot sense drop pipe failure
in meta sync and may lead to constantly skip of drop pipe (#12059)
add f5b88fb0e93 [IOTDB-6297] Optimize the distribute plan in the situation
of `aggregation with align by device`
add 33808fecd67 Merge branch 'master' into lmh/PredicatePushDown
add 27f824aa77e fix conflict with master
No new revisions were added by this update.
Summary of changes:
integration-test/pom.xml | 14 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 20 -
.../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 7 +-
.../test/java/org/apache/iotdb/spark/it/Utils.java | 1 -
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 1 -
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../plan/planner/LogicalPlanBuilder.java | 1 -
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 62 +--
.../planner/distribution/NodeDistribution.java | 24 +-
.../plan/planner/distribution/SourceRewriter.java | 327 +++++++++------
...anNodeRewriter.java => BaseSourceRewriter.java} | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 9 +
.../plan/planner/plan/node/PlanNode.java | 2 +-
.../plan/planner/plan/node/PlanNodeType.java | 7 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
...SortNode.java => AggregationMergeSortNode.java} | 25 +-
.../operator/AggregationOperatorTest.java | 17 +-
.../distribution/AggregationAlignByDeviceTest.java | 451 +++++++++++++++++++++
.../distribution/AggregationDistributionTest.java | 18 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 8 +-
22 files changed, 790 insertions(+), 228 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/{SimplePlanNodeRewriter.java
=> BaseSourceRewriter.java} (95%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/{MergeSortNode.java
=> AggregationMergeSortNode.java} (84%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AggregationAlignByDeviceTest.java
