This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch full_outer_join in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ec592af3d2934fb892a09e68515c1e777b67332b Merge: c04c6ed3725 6c78ead76d6 Author: Beyyes <[email protected]> AuthorDate: Wed Sep 25 08:25:07 2024 +0800 Merge branch 'add_coalesce' into full_outer_join .../iotdb/it/env/cluster/ClusterConstant.java | 4 +- .../org/apache/iotdb/it/env/cluster/EnvUtils.java | 18 +- .../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 19 ++ .../confignode/conf/ConfigNodeStartupCheck.java | 5 +- .../consensus/request/ConfigPhysicalPlanType.java | 1 + .../request/read/table/FetchTablePlan.java | 40 ++++ .../consensus/response/table/FetchTableResp.java | 44 +++++ .../iotdb/confignode/manager/ConfigManager.java | 23 +++ .../apache/iotdb/confignode/manager/IManager.java | 4 + .../iotdb/confignode/manager/ProcedureManager.java | 16 +- .../manager/load/balancer/RouteBalancer.java | 3 - .../manager/schema/ClusterSchemaManager.java | 16 ++ .../persistence/executor/ConfigPlanExecutor.java | 3 + .../persistence/schema/ClusterSchemaInfo.java | 23 +++ .../confignode/persistence/schema/ConfigMTree.java | 17 ++ .../impl/schema/table/AddTableColumnProcedure.java | 1 - .../impl/schema/table/CreateTableProcedure.java | 1 - .../schema/table/SetTablePropertiesProcedure.java | 1 - .../thrift/ConfigNodeRPCServiceProcessor.java | 7 + .../apache/iotdb/consensus/ConsensusFactory.java | 23 +-- .../consensus/config/PipeConsensusConfig.java | 26 ++- .../apache/iotdb/consensus/iot/IoTConsensus.java | 4 + .../consensus/iot/logdispatcher/LogDispatcher.java | 11 +- .../iotdb/consensus/ratis/RatisConsensus.java | 3 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 50 +++-- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 32 +-- .../db/consensus/DataRegionConsensusImpl.java | 4 +- .../agent/receiver/PipeDataNodeReceiverAgent.java | 2 +- .../pipeconsensus/PipeConsensusAsyncConnector.java | 4 +- .../pipeconsensus/PipeConsensusReceiver.java | 13 +- .../iotdb/db/protocol/client/ConfigNodeClient.java | 9 + .../config/executor/ClusterConfigTaskExecutor.java | 22 ++- .../config/executor/IConfigTaskExecutor.java | 4 + .../plan/planner/plan/node/write/InsertNode.java | 1 - .../fetcher/TableHeaderSchemaValidator.java | 60 ++++-- .../plan/relational/sql/ast/Expression.java | 3 + .../db/schemaengine/table/DataNodeTableCache.java | 217 ++++++++++++++++----- .../java/org/apache/iotdb/db/service/DataNode.java | 3 +- .../iotdb/db/storageengine/StorageEngine.java | 3 - .../db/storageengine/dataregion/DataRegion.java | 10 +- .../execute/task/AbstractCompactionTask.java | 2 +- .../task/InsertionCrossSpaceCompactionTask.java | 2 + .../task/RepairUnsortedFileCompactionTask.java | 4 + .../compaction/repair/RepairDataFileScanUtil.java | 10 +- .../repair/RepairTimePartitionScanTask.java | 2 +- .../dataregion/tsfile/TsFileResource.java | 2 +- .../FileTimeIndexCacheWriter.java | 8 +- .../storageengine/dataregion/wal/WALManager.java | 18 +- .../dataregion/wal/recover/WALNodeRecoverTask.java | 7 +- .../conf/iotdb-system.properties.template | 25 ++- .../assembly/resources/sbin/destroy-datanode.bat | 12 +- .../assembly/resources/sbin/destroy-datanode.sh | 4 +- .../apache/iotdb/commons/schema/table/TsTable.java | 4 +- .../schema/table/TsTableInternalRPCUtil.java | 94 ++++++--- .../org/apache/iotdb/commons/utils/PathUtils.java | 7 + .../src/main/thrift/confignode.thrift | 7 + 56 files changed, 713 insertions(+), 245 deletions(-)
