This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/agg_distribution_plan
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from df427ed8b6 Merge branch 'master' into xingtanzjr/agg_distribution_plan
add 16e444cbdb impl GroupByLevelDescriptor
add 319bc5dd3b refactor GroupByLevelNode
add 0ba7596d51 fix LogicalPlanBuilder and UT
add 1b7e09f684 fix DistributionPlannerTest
add 005580a866 add getInputColumnCandidateMap()
add 2e00d90db3 add getGroupedExpressionByLevel() in Analysis
add c6c05b8374 fix incorrect operatorType in OperatorContext
add c9ccd688a0 bug fix in LocalExecutionPlanner
visitRowBasedSeriesAggregate
add fe6eb7a6fd add AggregationDescriptorTest
add b930776e57 Merge remote-tracking branch 'upstream/master' into
groupByLevelNodeRefactor
add 21a0e5f3b9 merge master and resolve conflicts
add b753ab8164 fix compile error
add 4a541fa44d fix compile error
add fe190f0834 Merge branch 'master' into groupByLevelNodeRefactor
new cd227ab839 Merge branch 'groupByLevelNodeRefactor' into
xingtanzjr/agg_distribution_plan
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 18 ++
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 12 +-
.../mpp/plan/analyze/GroupByLevelController.java | 19 +-
.../db/mpp/plan/planner/DistributionPlanner.java | 10 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 32 +--
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 20 +-
.../planner/plan/node/process/AggregationNode.java | 3 +-
.../plan/node/process/GroupByLevelNode.java | 94 ++++----
.../planner/plan/node/process/MultiChildNode.java | 6 +
.../plan/parameter/AggregationDescriptor.java | 75 ++++++-
.../planner/plan/parameter/AggregationStep.java | 4 +
.../plan/parameter/GroupByLevelDescriptor.java | 107 +++++++++
.../plan/analyze/AggregationDescriptorTest.java | 238 +++++++++++++++++++++
.../db/mpp/plan/plan/DistributionPlannerTest.java | 76 +++----
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 134 ++++--------
.../node/process/GroupByLevelNodeSerdeTest.java | 7 +-
16 files changed, 616 insertions(+), 239 deletions(-)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupByLevelDescriptor.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/AggregationDescriptorTest.java
