This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira3188
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fdc90095b7 fix logBatchSize may exceed MAX_REQUEST_PER_BATCH
add ec6eba9305 [IOTDB-3242] Avoid generating same QueryId in different
DataNode (#6015)
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 8cc2bf6221 [IOTDB-3297] leader interface change (#6024)
add 327e07bf22 Fix Last Query Bug for Aligned (#6038)
add 6387b0e191 [IOTDB-3171] Fix NPE when getting modification file (#6033)
add b535b278dc Improve aligned write in tsfile api (#6021)
add 064c16679d Use cache for last query (#6042)
add 15fa098316 [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException:
Client has an error!Caused by: java.net.ConnectException: Connection refused
(#6043)
add 257ed97251 [IOTDB-3303] Support last query api for new cluster (#6030)
add 4de2073b1f Add GroupbyTimeParameter in GroupByLevelNode (#6044)
add 467243dbd4 [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException:
Client has an error!Caused by: java.net.ConnectException: Connection refused
(#6049)
add 8675ccb7ce [IOTDB-3129] Fix NPE bug while showing a non-exists
timeseries (#6050)
add 3b900430e8 Update last cache when insert (#6048)
add 3226bb7a74 fix aligned page reader bug (#6054)
add eb9b204475 update show ttl and show storage group. (#6040)
add 982140c9e7 Distribution plan for Align by device and GroupByLevel
(#6053)
add 790641dee0 Merge branch 'master' of github.com:Apache/iotdb into
jira3188
add ea3378139d fix review
No new revisions were added by this update.
Summary of changes:
.../exception/IllegalPeerEndpointException.java | 9 +-
.../multileader/MultiLeaderConsensus.java | 6 +
.../iotdb/consensus/ratis/RatisConsensus.java | 34 +--
.../consensus/standalone/StandAloneConsensus.java | 5 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 10 +-
docs/UserGuide/Reference/TSDB-Comparison.md | 7 +-
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 7 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +
.../engine/compaction/CompactionTaskManager.java | 2 +
.../compaction/cross/CrossSpaceCompactionTask.java | 44 ++--
.../compaction/inner/InnerSpaceCompactionTask.java | 80 +++----
.../compaction/task/AbstractCompactionTask.java | 1 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 42 +++-
.../db/engine/storagegroup/TsFileResource.java | 17 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 8 +
.../iotdb/db/metadata/path/MeasurementPath.java | 5 +
.../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 +++++
.../iotdb/db/mpp/common/header/HeaderConstant.java | 4 +-
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 122 +++++++++++
.../db/mpp/execution/operator/LastQueryUtil.java | 21 +-
.../operator/process/AggregationOperator.java | 4 +-
.../process/RawDataAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 144 ++++++++++++
.../operator/process/UpdateLastCacheOperator.java | 2 +
.../AlignedSeriesAggregationScanOperator.java | 12 +-
.../source/SeriesAggregationScanOperator.java | 16 +-
.../execution/operator/source/SeriesScanUtil.java | 3 +
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 15 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 4 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 73 ++++--
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 12 +-
.../db/mpp/plan/execution/QueryExecution.java | 6 +-
.../execution/config/ShowStorageGroupTask.java | 9 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 10 +-
.../db/mpp/plan/parser/StatementGenerator.java | 22 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 140 +++++++++---
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 106 ++++++---
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 25 ++-
.../planner/distribution/ExchangeNodeAdder.java | 42 +++-
.../plan/planner/distribution/SourceRewriter.java | 197 ++++++++++++++---
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 4 +-
.../planner/plan/node/process/AggregationNode.java | 41 ++--
.../planner/plan/node/process/DeviceMergeNode.java | 9 +-
.../planner/plan/node/process/DeviceViewNode.java | 14 +-
.../plan/node/process/GroupByLevelNode.java | 70 ++++--
.../plan/node/process/LastQueryMergeNode.java | 4 +-
...Node.java => SlidingWindowAggregationNode.java} | 67 +++---
.../plan/node/source/AlignedLastQueryScanNode.java | 14 +-
.../source/AlignedSeriesAggregationScanNode.java | 12 -
.../plan/node/source/LastQueryScanNode.java | 14 +-
.../node/source/SeriesAggregationScanNode.java | 12 -
.../node/source/SeriesAggregationSourceNode.java | 31 +++
.../planner/plan/node/write/InsertRowNode.java | 10 +
.../planner/plan/node/write/InsertTabletNode.java | 55 +++++
.../db/mpp/plan/statement/StatementVisitor.java | 7 +-
.../LastPointFetchStatement.java} | 31 ++-
.../SchemaFetchStatement.java | 2 +-
.../query/reader/chunk/MemAlignedPageReader.java | 15 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 4 +
.../java/org/apache/iotdb/db/service/DataNode.java | 32 +--
.../thrift/impl/DataNodeTSIServiceImpl.java | 99 +++++++--
.../service/thrift/impl/InternalServiceImpl.java | 5 +-
.../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 | 20 +-
.../distribution/AggregationDistributionTest.java | 16 +-
.../plan/distribution/AlignedByDeviceTest.java | 15 +-
...Test.java => DistributionPlannerBasicTest.java} | 2 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 118 ++++++++++
.../node/process/AggregationNodeSerdeTest.java | 3 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../.vuepress/theme/global-components/IoTDB.vue | 73 ++----
.../.vuepress/theme/global-components/IoTDBZH.vue | 82 +++----
.../iotdb/tsfile/read/reader/IPageReader.java | 4 +
.../tsfile/read/reader/page/AlignedPageReader.java | 13 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 3 +
.../write/chunk/AlignedChunkGroupWriterImpl.java | 85 ++++---
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 2 +-
92 files changed, 2439 insertions(+), 672 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/QueryIdGenerator.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
copy service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java =>
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java
(73%)
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
