This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-new-sql in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 43d213d1b7eba549b45313b1caf726577fc34e7b Merge: 8d8842dd2ba 1c2451af9b5 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Oct 9 15:26:39 2024 +0800 Merge branch 'master' of https://github.com/apache/iotdb into pipe-new-sql .../relational/it/db/it/IoTDBInsertTableIT.java | 79 ++++++ .../iotdb/session/it/IoTDBSessionSimpleIT.java | 37 +++ .../apache/iotdb/session/SessionConnection.java | 6 +- iotdb-core/ainode/resources/conf/ainode-env.bat | 4 +- iotdb-core/ainode/resources/conf/ainode-env.sh | 4 +- .../iotdb/confignode/conf/ConfigNodeConfig.java | 2 + .../execution/exchange/SharedTsBlockQueue.java | 10 + .../exchange/source/LocalSourceHandle.java | 12 + .../operator/schema/source/DeviceSchemaSource.java | 2 +- .../source/ActiveDeviceRegionScanOperator.java | 2 +- .../execution/operator/source/SeriesScanUtil.java | 16 +- .../db/queryengine/plan/analyze/TypeProvider.java | 10 +- .../analyze/cache/schema/DataNodeTTLCache.java | 62 ++--- .../plan/planner/OperatorTreeGenerator.java | 8 +- .../plan/planner/plan/node/PlanNodeType.java | 8 + .../plan/relational/function/BoundSignature.java | 36 +++ .../plan/relational/function/FunctionKind.java | 20 +- .../plan/relational/metadata/ColumnSchema.java | 47 +--- .../relational/metadata/FunctionNullability.java | 31 +++ .../plan/relational/metadata/ResolvedFunction.java | 32 ++- .../relational/planner/node/AggregationNode.java | 219 +++++++++++++++- .../planner/node/AggregationTableScanNode.java | 275 +++++++++++++++++++++ .../plan/relational/utils/TypeUtil.java | 105 ++++++++ .../java/org/apache/iotdb/db/service/DataNode.java | 4 +- .../iotdb/db/storageengine/StorageEngine.java | 8 +- .../db/storageengine/dataregion/DataRegion.java | 47 ++-- .../execute/performer/ICompactionPerformer.java | 2 - .../performer/impl/FastCompactionPerformer.java | 49 ++-- .../impl/ReadChunkCompactionPerformer.java | 16 +- .../impl/ReadPointCompactionPerformer.java | 10 +- .../RepairUnsortedFileCompactionPerformer.java | 3 +- .../task/RepairUnsortedFileCompactionTask.java | 10 +- .../execute/utils/MultiTsFileDeviceIterator.java | 42 ++-- .../ReadChunkAlignedSeriesCompactionExecutor.java | 8 +- .../repair/RepairTimePartitionScanTask.java | 6 +- .../schedule/CompactionScheduleContext.java | 25 +- .../selector/impl/SettleSelectorImpl.java | 16 +- .../impl/SizeTieredCompactionSelector.java | 3 +- .../dataregion/memtable/TsFileProcessor.java | 13 +- .../dataregion/read/QueryDataSource.java | 5 + .../load/active/ActiveLoadDirScanner.java | 13 + .../load/active/ActiveLoadTsFileLoader.java | 15 ++ .../db/storageengine/dataregion/TTLQueryTest.java | 14 +- .../iotdb/db/storageengine/dataregion/TTLTest.java | 46 ++-- .../compaction/AbstractCompactionTest.java | 3 +- .../repair/RepairUnsortedFileCompactionTest.java | 32 +-- .../settle/SettleCompactionRecoverTest.java | 2 +- .../settle/SettleCompactionSelectorTest.java | 14 +- .../settle/SettleCompactionTaskTest.java | 22 +- .../tablemodel/CompactionWithAllNullRowsTest.java | 9 +- .../TableModelCompactionWithTTLTest.java | 191 ++++++++++++++ .../compaction/utils/CompactionCheckerUtils.java | 3 +- .../utils/MultiTsFileDeviceIteratorTest.java | 38 +-- .../apache/iotdb/commons/schema/table/TsTable.java | 15 ++ pom.xml | 2 +- 55 files changed, 1393 insertions(+), 320 deletions(-)
