This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-3227
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c9355e5d54 register function in UDFInfo
add 18638376c1 [IOTDB-3231] Return detailed failure message for opening a
client (#5989)
add acac1cfb18 Fix time iterator bug in MPP (#5992)
add 383488a715 Distribution plan for Aggregation Query (#5982)
add 1f9bef5d7c [IOTDB-2964] Fix exception occurs when selecting cross
space compaction task (#5633)
add 8b2af2ebb8 Bump gson from 2.8.8 to 2.8.9 (#5978)
new 5c94f7d8a0 Merge branch 'master' of github.com:apache/iotdb into
iotdb-3227
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:
pom.xml | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 11 +-
.../selector/RewriteCompactionFileSelector.java | 6 +-
.../timerangeiterator/AggrWindowIterator.java | 9 +-
.../timerangeiterator/PreAggrWindowIterator.java | 9 +-
.../PreAggrWindowWithNaturalMonthIterator.java | 9 +-
.../SingleTimeWindowIterator.java | 12 +-
.../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 | 280 +++++++++++--
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 46 ++-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 20 +-
.../planner/plan/node/process/AggregationNode.java | 21 +-
.../plan/node/process/GroupByLevelNode.java | 92 ++---
.../{ProcessNode.java => MultiChildNode.java} | 22 +-
.../planner/plan/node/process/TimeJoinNode.java | 15 +-
.../source/AlignedSeriesAggregationScanNode.java | 23 +-
.../plan/node/source/AlignedSeriesScanNode.java | 13 +-
.../node/source/SeriesAggregationScanNode.java | 38 +-
...eNode.java => SeriesAggregationSourceNode.java} | 26 +-
.../planner/plan/node/source/SeriesScanNode.java | 13 +-
.../SinkNode.java => source/SeriesSourceNode.java} | 15 +-
.../plan/parameter/AggregationDescriptor.java | 86 +++-
.../planner/plan/parameter/AggregationStep.java | 4 +
.../plan/parameter/GroupByLevelDescriptor.java | 107 +++++
.../thrift/impl/DataNodeTSIServiceImpl.java | 9 +-
.../cross/RewriteCompactionFileSelectorTest.java | 42 ++
.../plan/analyze/AggregationDescriptorTest.java | 238 +++++++++++
.../db/mpp/plan/plan/DistributionPlannerTest.java | 438 ++++++++++++++++++++-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 134 ++-----
.../node/process/GroupByLevelNodeSerdeTest.java | 7 +-
.../iotdb/rpc/ConfigNodeConnectionException.java | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
34 files changed, 1490 insertions(+), 309 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{ProcessNode.java
=> MultiChildNode.java} (66%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/{SourceNode.java
=> SeriesAggregationSourceNode.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/{sink/SinkNode.java
=> source/SeriesSourceNode.java} (70%)
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
