This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/TableModelGrammar_DistributePlan in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8f4d9bbe7aa5872b62afec0b40a5c59e5f78061d Merge: e9583f870c9 50d8708f2ec Author: Beyyes <[email protected]> AuthorDate: Wed Jun 12 15:43:49 2024 +0800 Merge branch 'ty/TableModelGrammar' of github.com:apache/iotdb into ty/TableModelGrammar distribution/src/assembly/all.xml | 9 + distribution/src/assembly/confignode.xml | 9 + distribution/src/assembly/datanode.xml | 9 + .../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 2 +- .../iotdb/db/it/IoTDBSetConfigurationIT.java | 89 +++++++ .../java/org/apache/iotdb/db/it/IoTDBSettleIT.java | 2 +- .../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 5 +- .../db/it/aggregation/IoTDBAggregationIT.java | 15 +- .../db/it/aggregation/maxby/IoTDBMaxByIT.java | 3 +- .../db/it/aggregation/minby/IoTDBMinByIT.java | 3 +- .../iotdb/db/it/udf/IoTDBUDFWindowQuery2IT.java | 216 ++++++++++++++++ .../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +- .../java/org/apache/iotdb/cli/AbstractCli.java | 34 ++- .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 8 + .../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 4 +- .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 4 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +- .../assembly/resources/sbin/stop-confignode.bat | 19 +- .../confignode/client/ConfigNodeRequestType.java | 4 +- .../confignode/client/DataNodeRequestType.java | 2 + .../client/async/AsyncDataNodeClientPool.java | 7 + .../client/sync/SyncConfigNodeClientPool.java | 3 + .../client/sync/SyncDataNodeClientPool.java | 8 +- .../confignode/conf/ConfigNodeDescriptor.java | 6 +- .../iotdb/confignode/manager/ConfigManager.java | 52 ++++ .../apache/iotdb/confignode/manager/IManager.java | 8 + .../iotdb/confignode/manager/node/NodeManager.java | 107 +++++++- .../manager/partition/PartitionManager.java | 2 +- .../persistence/pipe/PipePluginInfo.java | 39 +-- .../procedure/env/ConfigNodeProcedureEnv.java | 22 +- .../procedure/env/RegionMaintainHandler.java | 78 +++--- .../impl/sync/AuthOperationProcedure.java | 11 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 12 + .../src/assembly/resources/sbin/stop-datanode.bat | 24 +- .../org/apache/iotdb/db/audit/AuditLogger.java | 1 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 +- .../iotdb/db/protocol/client/ConfigNodeClient.java | 14 ++ .../protocol/thrift/impl/ClientRPCServiceImpl.java | 71 +++++- .../impl/DataNodeInternalRPCServiceImpl.java | 22 ++ .../db/queryengine/plan/analyze/Analysis.java | 11 + .../db/queryengine/plan/analyze/IAnalysis.java | 16 ++ .../plan/analyze/LoadTsfileAnalyzer.java | 8 + .../plan/execution/config/ConfigTaskVisitor.java | 8 + .../config/executor/ClusterConfigTaskExecutor.java | 87 +++++-- .../config/executor/IConfigTaskExecutor.java | 3 + .../execution/config/sys/SetConfigurationTask.java | 45 ++++ .../db/queryengine/plan/parser/ASTVisitor.java | 20 ++ .../distribution/WriteFragmentParallelPlanner.java | 11 +- .../plan/planner/plan/node/WritePlanNode.java | 4 +- .../plan/node/load/LoadSingleTsFileNode.java | 4 +- .../planner/plan/node/load/LoadTsFileNode.java | 9 +- .../plan/node/load/LoadTsFilePieceNode.java | 4 +- .../node/metedata/write/ActivateTemplateNode.java | 4 +- .../node/metedata/write/AlterTimeSeriesNode.java | 4 +- .../metedata/write/BatchActivateTemplateNode.java | 4 +- .../write/CreateAlignedTimeSeriesNode.java | 4 +- .../metedata/write/CreateMultiTimeSeriesNode.java | 4 +- .../node/metedata/write/CreateTimeSeriesNode.java | 4 +- .../write/InternalBatchActivateTemplateNode.java | 4 +- .../write/InternalCreateMultiTimeSeriesNode.java | 4 +- .../write/InternalCreateTimeSeriesNode.java | 4 +- .../metedata/write/view/CreateLogicalViewNode.java | 4 +- .../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 4 +- .../plan/node/pipe/PipeEnrichedInsertNode.java | 4 +- .../plan/node/pipe/PipeEnrichedWritePlanNode.java | 4 +- .../planner/plan/node/write/DeleteDataNode.java | 5 +- .../plan/node/write/InsertMultiTabletsNode.java | 4 +- .../planner/plan/node/write/InsertRowNode.java | 4 +- .../planner/plan/node/write/InsertRowsNode.java | 4 +- .../plan/node/write/InsertRowsOfOneDeviceNode.java | 4 +- .../planner/plan/node/write/InsertTabletNode.java | 4 +- .../plan/relational/analyzer/Analysis.java | 28 +++ .../metadata/ITableDeviceSchemaValidation.java | 66 +++++ .../plan/relational/metadata/Metadata.java | 30 +++ .../relational/metadata/TableMetadataImpl.java | 13 + .../fetcher/cache/TableDeviceCacheEntry.java | 55 +++++ .../metadata/fetcher/cache/TableDeviceId.java | 62 +++++ .../fetcher/cache/TableDeviceSchemaCache.java | 86 +++++++ .../relational/metadata/fetcher/cache/TableId.java | 67 +++++ .../distribute/TableDistributionPlanner.java | 5 +- ...or.java => TableModelQueryFragmentPlanner.java} | 7 +- .../queryengine/plan/statement/StatementType.java | 1 + .../plan/statement/StatementVisitor.java | 5 + .../statement/sys/SetConfigurationStatement.java | 72 ++++++ .../dag/intermediate/MultiInputLayer.java | 5 +- .../SingleInputMultiReferenceLayer.java | 12 +- .../SingleInputSingleReferenceLayer.java | 12 +- .../iotdb/db/storageengine/StorageEngine.java | 42 ++++ .../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +- .../plan/relational/analyzer/TestMatadata.java | 14 ++ .../fetcher/cache/TableDeviceSchemaCacheTest.java | 100 ++++++++ iotdb-core/node-commons/pom.xml | 76 ++++++ .../resources/conf/generate_properties.bat | 64 +++++ .../assembly/resources/conf/generate_properties.sh | 59 +++++ .../resources/conf/iotdb-system.properties | 2 +- .../iotdb/commons/conf/CommonDescriptor.java | 5 +- .../commons/conf/ConfigFileAutoUpdateTool.java | 126 ---------- .../iotdb/commons/conf/ConfigurationFileUtils.java | 275 +++++++++++++++++++++ .../commons/partition/SeriesPartitionTable.java | 28 +-- .../pipe/connector/protocol/IoTDBConnector.java | 28 ++- .../apache/iotdb/commons/schema/MemUsageUtil.java | 2 +- .../thrift-commons/src/main/thrift/common.thrift | 18 +- .../src/main/thrift/confignode.thrift | 6 + .../thrift-datanode/src/main/thrift/client.thrift | 4 + .../src/main/thrift/datanode.thrift | 4 + 105 files changed, 2259 insertions(+), 383 deletions(-)
