You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/05/26 13:07:55 UTC
[iotdb] branch last_query_api updated (35a793d453 -> ab15c47ecd)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch last_query_api
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 35a793d453 Support last query api in new cluster
add 0d8d00443e [IOTDB-3286] False Carousel Ratio on Desktop Version Homepage (#6028)
add 1f3152976a [IOTDB-3040] Fix TTL cannot delete the expired tsfile (#5895)
add 5eb0a8f38e [IOTDB-3294] Update database comparison docs (#6027)
add 5e368d4eef [IOTDB-3081] Implementation of SlidingWindowAggregationOperator (#5986)
add f78561434d Implement LastPointFetchStatement (#6036)
add 120a8c2fbe [IoTDB-3304] complete last query distribution plan (#6031)
add ab15c47ecd Merge branch 'master' of https://github.com/apache/iotdb into last_query_api
No new revisions were added by this update.
Summary of changes:
docs/UserGuide/Reference/TSDB-Comparison.md | 7 +-
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 7 +-
.../engine/compaction/CompactionTaskManager.java | 2 +
.../compaction/cross/CrossSpaceCompactionTask.java | 44 ++--
.../compaction/inner/InnerSpaceCompactionTask.java | 80 +++----
.../compaction/task/AbstractCompactionTask.java | 1 +
.../db/engine/storagegroup/TsFileResource.java | 11 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 22 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 6 +
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 2 +-
.../EmptyQueueSlidingWindowAggregator.java} | 35 +--
.../MonotonicQueueSlidingWindowAggregator.java | 76 +++++++
.../NormalQueueSlidingWindowAggregator.java} | 40 ++--
.../slidingwindow/SlidingWindowAggregator.java | 143 ++++++++++++
.../SlidingWindowAggregatorFactory.java | 149 +++++++++++++
.../SmoothQueueSlidingWindowAggregator.java | 57 +++++
.../operator/process/AggregationOperator.java | 4 +-
.../process/RawDataAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 144 ++++++++++++
.../AlignedSeriesAggregationScanOperator.java | 12 +-
.../source/SeriesAggregationScanOperator.java | 16 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 73 ++++--
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 2 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 75 +++++--
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 73 +++---
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 19 +-
.../planner/distribution/ExchangeNodeAdder.java | 19 ++
.../plan/planner/distribution/SourceRewriter.java | 93 +++++---
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 4 +-
.../planner/plan/node/process/AggregationNode.java | 46 ++--
.../plan/node/process/LastQueryMergeNode.java | 4 +-
...Node.java => SlidingWindowAggregationNode.java} | 67 +++---
.../plan/node/source/AlignedLastQueryScanNode.java | 14 +-
.../plan/node/source/LastQueryScanNode.java | 14 +-
.../db/mpp/plan/statement/StatementVisitor.java | 7 +-
.../LastPointFetchStatement.java} | 31 ++-
.../SchemaFetchStatement.java | 2 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 25 +++
.../compaction/CompactionTaskManagerTest.java | 31 +--
.../operator/AggregationOperatorTest.java | 2 +-
.../SlidingWindowAggregationOperatorTest.java | 244 +++++++++++++++++++++
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 12 +-
...Test.java => DistributionPlannerBasicTest.java} | 2 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 118 ++++++++++
.../node/process/AggregationNodeSerdeTest.java | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../.vuepress/theme/global-components/IoTDB.vue | 73 ++----
.../.vuepress/theme/global-components/IoTDBZH.vue | 82 +++----
50 files changed, 1567 insertions(+), 442 deletions(-)
copy server/src/main/java/org/apache/iotdb/db/{query/executor/groupby/impl/EmptyQueueSlidingWindowGroupByExecutor.java => mpp/aggregation/slidingwindow/EmptyQueueSlidingWindowAggregator.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/MonotonicQueueSlidingWindowAggregator.java
copy server/src/main/java/org/apache/iotdb/db/{query/executor/groupby/impl/NormalQueueSlidingWindowGroupByExecutor.java => mpp/aggregation/slidingwindow/NormalQueueSlidingWindowAggregator.java} (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SlidingWindowAggregator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SlidingWindowAggregatorFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/SlidingWindowAggregationOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{GroupByTimeNode.java => SlidingWindowAggregationNode.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/DeleteTimeSeriesStatement.java => internal/LastPointFetchStatement.java} (59%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata => internal}/SchemaFetchStatement.java (97%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SlidingWindowAggregationOperatorTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/{BasicTest.java => DistributionPlannerBasicTest.java} (99%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/LastQueryTest.java