This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 87b86ffa337 Merge branch 'pipe-meta-sync' of
https://github.com/apache/iotdb into pipe-meta-sync
add f5b88fb0e93 [IOTDB-6297] Optimize the distribute plan in the situation
of `aggregation with align by device`
add 8b5a6d7bfa7 [IOTDB-6298] Fix number overflow in group by time interval
add b5dfbfd4129 [IOTDB-6299] Fix bug in merging overlapped data process
caused by filter & offset push down
add 2a91bb5904e Introduce Aggregation Function MinBy
add 5f796ba7c8d Add recover IT for Procedure, and delete ProcedureStore
(#12045)
add bc8d866f4e8 PBTree: Implement dual-buffer container for MNode
management (#12048)
add b65a73b192e Merge branch 'master' of https://github.com/apache/iotdb
into pipe-meta-sync
No new revisions were added by this update.
Summary of changes:
.../constant/BuiltinAggregationFunctionEnum.java | 3 +-
.../confignode/it/procedure/IoTDBProcedureIT.java | 137 +++++++
.../db/it/aggregation/IoTDBAggregationIT.java | 52 +++
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 3 +-
.../IoTDBMinBy2IT.java} | 4 +-
.../IoTDBMinBy3IT.java} | 4 +-
.../IoTDBMinByAlignedSeriesIT.java} | 24 +-
.../IoTDBMaxByIT.java => minby/IoTDBMinByIT.java} | 131 +++---
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 48 +++
.../java/org/apache/iotdb/tool/ExportTsFile.java | 3 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 1 +
.../sql/factory/IoTDBDynamicTableFactory.java | 1 +
.../iotdb/confignode/manager/ConfigManager.java | 7 +
.../apache/iotdb/confignode/manager/IManager.java | 9 +
.../iotdb/confignode/manager/ProcedureManager.java | 13 +-
.../confignode/persistence/ProcedureInfo.java | 7 +-
.../iotdb/confignode/procedure/Procedure.java | 15 +
.../confignode/procedure/ProcedureExecutor.java | 2 +
.../impl/CreateManyDatabasesProcedure.java | 116 ++++++
.../procedure/store/ProcedureFactory.java | 9 +-
.../confignode/procedure/store/ProcedureStore.java | 192 ---------
.../confignode/procedure/store/ProcedureType.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 5 +
...TestSTMProcedure.java => STMProcedureTest.java} | 2 +-
.../procedure/store/TestProcedureStore.java | 113 ------
.../iotdb/db/protocol/client/ConfigNodeClient.java | 6 +
.../execution/aggregation/AccumulatorFactory.java | 4 +
.../execution/aggregation/MaxByAccumulator.java | 404 +-----------------
...cumulator.java => MaxMinByBaseAccumulator.java} | 63 +--
.../execution/aggregation/MinByAccumulator.java} | 39 +-
.../SlidingWindowAggregatorFactory.java | 34 ++
.../execution/operator/source/SeriesScanUtil.java | 38 +-
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../plan/analyze/ExpressionTypeAnalyzer.java | 1 +
.../db/queryengine/plan/parser/ASTVisitor.java | 1 +
.../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 | 328 +++++++++------
...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} | 30 +-
.../plan/parameter/AggregationDescriptor.java | 3 +
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 9 +
.../mtree/impl/pbtree/memory/MemoryManager.java | 37 +-
.../mnode/container/CachedMNodeContainer.java | 148 +++----
.../mnode/container/ICachedMNodeContainer.java | 18 +-
.../container/IMNodeChildBuffer.java} | 38 +-
.../pbtree/mnode/container/MNodeChildBuffer.java | 331 +++++++++++++++
.../mnode/container/MNodeNewChildBuffer.java | 75 ++++
.../mnode/container/MNodeUpdateChildBuffer.java | 83 ++++
.../impl/pbtree/schemafile/MockSchemaFile.java | 6 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 9 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 6 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 5 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +
.../iotdb/db/utils/constant/SqlConstant.java | 1 +
.../iotdb/db/utils/constant/TestConstant.java | 4 +
.../metadata/container/MNodeChildBufferTest.java | 125 ++++++
.../mtree/schemafile/SchemaFileLogTest.java | 4 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 129 +++---
.../execution/aggregation/AccumulatorTest.java | 33 ++
.../operator/AggregationOperatorTest.java | 17 +-
.../distribution/AggregationAlignByDeviceTest.java | 451 +++++++++++++++++++++
.../distribution/AggregationDistributionTest.java | 18 +-
.../AlignedSeriesScanPredicatePushDownTest.java | 7 +-
.../series/SeriesScanLimitOffsetPushDownTest.java | 5 +
.../series/SeriesScanPredicatePushDownTest.java | 23 +-
.../iotdb/db/tools/PBTreeFileSketchTest.java | 5 +
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 3 +
.../udf/builtin/BuiltinAggregationFunction.java | 5 +-
.../org/apache/iotdb/commons/utils/TestOnly.java | 8 +-
.../tsfile/read/common/block/TsBlockUtil.java | 55 +++
.../tsfile/read/reader/page/AlignedPageReader.java | 54 +--
.../thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/confignode.thrift | 3 +
80 files changed, 2382 insertions(+), 1319 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/procedure/IoTDBProcedureIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxBy2IT.java
=> minby/IoTDBMinBy2IT.java} (93%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxBy3IT.java
=> minby/IoTDBMinBy3IT.java} (93%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxByAlignedSeriesIT.java
=> minby/IoTDBMinByAlignedSeriesIT.java} (89%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxByIT.java
=> minby/IoTDBMinByIT.java} (78%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/CreateManyDatabasesProcedure.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ProcedureStore.java
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/{TestSTMProcedure.java
=> STMProcedureTest.java} (97%)
delete mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/store/TestProcedureStore.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/{MaxByAccumulator.java
=> MaxMinByBaseAccumulator.java} (86%)
copy
iotdb-core/{tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedBatchReader.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/MinByAccumulator.java}
(57%)
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%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{memory/buffer/INodeBuffer.java
=> mnode/container/IMNodeChildBuffer.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/container/MNodeChildBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/container/MNodeNewChildBuffer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/container/MNodeUpdateChildBuffer.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/container/MNodeChildBufferTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AggregationAlignByDeviceTest.java
