This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/join in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 733a542ba040d6431f2735509186f00a8b7727e9 Merge: 36755a3e1a6 bc3b4d32c11 Author: Beyyes <[email protected]> AuthorDate: Mon Aug 26 10:15:53 2024 +0800 Merge branch 'master' into beyyes/join .github/workflows/cluster-it-1c1d.yml | 2 - .github/workflows/cluster-it-1c3d.yml | 4 +- .github/workflows/{unit-test.yml => daily-ut.yml} | 30 +- .github/workflows/multi-language-client.yml | 12 +- .github/workflows/pipe-it-2cluster.yml | 96 +- ...uster-it-1c1d.yml => table-cluster-it-1c1d.yml} | 8 +- ...uster-it-1c3d.yml => table-cluster-it-1c3d.yml} | 10 +- .github/workflows/unit-test.yml | 11 +- example/pipe-count-point-processor/pom.xml | 2 +- integration-test/README.md | 24 +- integration-test/pom.xml | 62 +- .../java/org/apache/iotdb/it/env/EnvFactory.java | 2 + .../main/java/org/apache/iotdb/it/env/EnvType.java | 3 +- .../it/env/cluster/config/MppCommonConfig.java | 6 +- .../env/cluster/config/MppSharedCommonConfig.java | 7 +- .../iotdb/it/env/cluster/env/AbstractEnv.java | 5 +- .../it/env/remote/config/RemoteCommonConfig.java | 3 +- ...ltiClusterIT2SubscriptionArchVerification.java} | 2 +- ...iClusterIT2SubscriptionRegressionConsumer.java} | 2 +- ...MultiClusterIT2SubscriptionRegressionMisc.java} | 2 +- ...terIT2Subscription.java => TableClusterIT.java} | 2 +- ...bscription.java => TableLocalStandaloneIT.java} | 2 +- .../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +- .../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 2 +- .../org/apache/iotdb/db/it/IoTDBRestartIT.java | 54 +- .../org/apache/iotdb/db/it/utils/TestUtils.java | 25 +- .../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 97 + .../it/db/it/IoTDBExecuteBatchTableIT.java | 7 +- .../it/db/it/IoTDBFlushQueryTableIT.java | 6 +- .../it/db/it/IoTDBInsertAlignedValuesTableIT.java | 6 +- .../relational/it/db/it/IoTDBInsertTableIT.java | 391 ++- .../it/db/it/IoTDBMultiDeviceTableIT.java | 6 +- .../it}/IoTDBMultiIDsWithAttributesTableIT.java | 43 +- .../relational/it/db/it/IoTDBRecoverTableIT.java | 6 +- .../it/db/it/IoTDBRecoverUnclosedTableIT.java | 6 +- .../relational/it/db/it/IoTDBRestartTableIT.java | 90 +- .../it/db/it/IoTDBSetConfigurationTableIT.java | 25 +- .../it/query/old/IoTDBDatetimeFormatTableIT.java | 6 +- .../it/query/old/IoTDBFilterBetweenTableIT.java | 6 +- .../it/query/old/IoTDBFilterNullTableIT.java | 6 +- .../it/query/old/IoTDBFilterTableIT.java | 5 +- .../it/query/old/IoTDBNestedQueryTableIT.java | 25 +- .../it/query/old/IoTDBSimpleQueryTableIT.java | 6 +- .../alignbydevice/IoTDBAlignByDeviceTable2IT.java | 6 +- .../alignbydevice/IoTDBAlignByDeviceTable3IT.java | 6 +- .../alignbydevice/IoTDBAlignByDeviceTableIT.java | 6 +- .../IoTDBAlignByDeviceWithTemplateTable2IT.java | 6 +- .../IoTDBAlignByDeviceWithTemplateTableIT.java | 6 +- ...TDBOrderByLimitOffsetAlignByDeviceTable2IT.java | 6 +- ...oTDBOrderByLimitOffsetAlignByDeviceTableIT.java | 6 +- .../IoTDBOrderByWithAlignByDeviceTable2IT.java | 6 +- .../IoTDBOrderByWithAlignByDeviceTable3IT.java | 6 +- .../IoTDBOrderByWithAlignByDeviceTableIT.java | 6 +- .../IoTDBAlignedOffsetLimitPushDownTableIT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable2IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable3IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable4IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTable5IT.java | 6 +- .../aligned/IoTDBAlignedSeriesQueryTableIT.java | 6 +- .../aligned/IoTDBPredicatePushDownTable2IT.java | 6 +- .../aligned/IoTDBPredicatePushDownTable3IT.java | 6 +- .../aligned/IoTDBPredicatePushDownTable4IT.java | 6 +- .../old/aligned/IoTDBPredicatePushDownTableIT.java | 6 +- .../scalar/IoTDBCastFunctionTableIT.java | 6 +- .../scalar/IoTDBDiffFunctionTable2IT.java | 6 +- .../scalar/IoTDBDiffFunctionTable3IT.java | 6 +- .../scalar/IoTDBDiffFunctionTableIT.java | 6 +- .../scalar/IoTDBReplaceFunctionTableIT.java | 6 +- .../scalar/IoTDBRoundFunctionTableIT.java | 6 +- .../scalar/IoTDBScalarFunctionTableIT.java | 2723 ++++++++++++++++++++ .../scalar/IoTDBSubStringFunctionTableIT.java | 6 +- .../it/query/old/orderBy/IoTDBOrderByTableIT.java | 6 +- .../it/query/old/query/IoTDBArithmeticTableIT.java | 6 +- .../query/old/query/IoTDBCaseWhenThenTableIT.java | 6 +- .../it/query/old/query/IoTDBFuzzyQueryTableIT.java | 6 +- .../it/query/old/query/IoTDBInTableIT.java | 6 +- ...oTDBNoSelectExpressionAfterAnalyzedTableIT.java | 6 +- .../query/old/query/IoTDBNullOperandTableIT.java | 6 +- .../query/old/query/IoTDBNullValueFillTableIT.java | 6 +- .../it/query/old/query/IoTDBPaginationTableIT.java | 6 +- .../it/query/old/query/IoTDBQueryDemoTableIT.java | 6 +- .../IoTDBQueryWithComplexValueFilterTableIT.java | 20 +- .../it/query/old/query/IoTDBResultSetTableIT.java | 6 +- .../query/IoTDBSelectCompareExpressionTableIT.java | 6 +- .../query/old/query/IoTDBSelectSchemaTableIT.java | 6 +- .../it/query/recent/IoTDBNullIdQueryIT.java | 6 +- .../relational/it/schema/IoTDBDatabaseIT.java | 6 +- .../iotdb/relational/it/schema/IoTDBDeviceIT.java | 220 ++ .../relational/it/schema/IoTDBDeviceQueryIT.java | 109 - .../iotdb/relational/it/schema/IoTDBTableIT.java | 74 +- .../it/session/IoTDBTableModelSessionIT.java | 6 +- .../session/pool/IoTDBTableModelSessionPoolIT.java | 6 +- .../iotdb/session/it/IoTDBSessionRelationalIT.java | 87 +- .../subscription/it/AbstractSubscriptionIT.java | 13 +- .../apache/iotdb/subscription/it/DisplayName.java | 21 +- .../it/SkipOnSetUpAndTearDownFailure.java | 114 + .../iotdb/subscription/it/SkipOnSetUpFailure.java | 82 - .../it/cluster/IoTDBSubscriptionRestartIT.java | 98 +- .../it/dual/AbstractSubscriptionDualIT.java | 10 +- .../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 10 +- .../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 6 +- .../it/dual/IoTDBSubscriptionTopicIT.java | 18 +- .../it/local/AbstractSubscriptionLocalIT.java | 10 +- .../it/local/IoTDBSubscriptionBasicIT.java | 4 +- .../it/local/IoTDBSubscriptionDataTypeIT.java | 2 +- .../it/triple/AbstractSubscriptionTripleIT.java | 10 +- .../it/triple/IoTDBSubscriptionSharingIT.java | 18 +- .../AbstractSubscriptionRegressionIT.java | 475 ++++ .../IoTDBDefaultPullConsumerDataSetIT.java | 142 + .../IoTDBDefaultTsfilePushConsumerIT.java | 224 ++ .../IoTDBRootDatasetPushConsumerIT.java | 186 ++ .../IoTDBRootPullConsumeTsfileIT.java | 147 ++ ...merPullConsumerWith1TopicShareProcessMixIT.java | 196 ++ .../param/IoTDBTestParamPullConsumerIT.java | 534 ++++ .../param/IoTDBTestParamPushConsumerIT.java | 349 +++ .../param/IoTDBTestParamSubscriptionSessionIT.java | 70 + .../regression/param/IoTDBTestParamTopicIT.java | 248 ++ ...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 191 ++ ...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 175 ++ .../format/IoTDBDBDataSetPullConsumerIT.java | 154 ++ .../format/IoTDBDBTsfilePullConsumerIT.java | 155 ++ .../IoTDBAllTsDatasetPullConsumerIT.java | 208 ++ .../IoTDBAllTsTsfilePullConsumerIT.java | 199 ++ .../IoTDBAllTsfilePullConsumerSnapshotIT.java | 201 ++ .../IoTDBPathDeviceDataSetPullConsumerIT.java | 170 ++ .../IoTDBPathDeviceTsfilePullConsumerIT.java | 189 ++ .../IoTDBTimeTsDatasetPullConsumerIT.java | 212 ++ .../IoTDBTimeTsTsfilePullConsumerIT.java | 203 ++ .../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 152 ++ .../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 182 ++ ...DBConsumer2With1TopicShareProcessDataSetIT.java | 145 ++ ...TDBConsumer2With1TopicShareProcessTsfileIT.java | 198 ++ .../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 215 ++ .../IoTDBOneConsumerMultiTopicsDatasetIT.java | 183 ++ .../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 319 +++ .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++ .../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 177 ++ .../IoTDBDBPatternPullConsumerDataSetIT.java | 150 ++ .../IoTDBDefaultPatternPullConsumerDataSetIT.java | 145 ++ .../IoTDBDevicePatternPullConsumeTsfileIT.java | 176 ++ .../IoTDBDevicePatternPullConsumerDataSetIT.java | 156 ++ ...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 174 ++ ...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 177 ++ ...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 184 ++ .../IoTDBRootPatternPullConsumeTsfileIT.java | 152 ++ .../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 182 ++ .../IoTDBTSPatternPullConsumerDataSetIT.java | 132 + .../time/IoTDBAllPullConsumerDataSetIT.java | 131 + .../time/IoTDBHistoryPullConsumerDataSetIT.java | 139 + .../time/IoTDBRealTimePullConsumerDataSetIT.java | 138 + ...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 136 + .../time/IoTDBTimeRangePullConsumerDataSetIT.java | 140 + .../format/IoTDBTestPushConsumeDataSetIT.java | 179 ++ .../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 181 ++ .../format/IoTDBTestPushConsumeTsfileIT.java | 181 ++ .../IoTDBLooseAllTsDatasetPushConsumerIT.java | 228 ++ ...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 227 ++ .../IoTDBLooseAllTsfilePushConsumerIT.java | 257 ++ .../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 254 ++ .../IoTDBPathLooseTsDatasetPushConsumerIT.java | 255 ++ .../IoTDBPathLooseTsfilePushConsumerIT.java | 224 ++ .../IoTDBPathTsLooseDatasetPushConsumerIT.java | 209 ++ .../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 220 ++ .../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 277 ++ .../IoTDBTimeLooseTsfilePushConsumerIT.java | 237 ++ .../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 219 ++ ...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 196 ++ ...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 246 ++ ...DBConsumer2With1TopicShareProcessDataSetIT.java | 216 ++ ...TDBConsumer2With1TopicShareProcessTsfileIT.java | 223 ++ .../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 604 +++++ .../IoTDBOneConsumerMultiTopicsDatasetIT.java | 202 ++ .../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 239 ++ .../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++ .../IoTDBDBPatternDatasetPushConsumerIT.java | 191 ++ .../IoTDBDBPatternTsfilePushConsumerIT.java | 221 ++ .../IoTDBDefaultPatternTsfilePushConsumerIT.java | 220 ++ .../IoTDBDevicePatternDatasetPushConsumerIT.java | 190 ++ .../IoTDBDevicePatternTsfilePushConsumerIT.java | 233 ++ .../IoTDBRootPatternDatasetPushConsumerIT.java | 191 ++ .../IoTDBTSPatternDatasetPushConsumerIT.java | 190 ++ .../IoTDBTSPatternTsfilePushConsumerIT.java | 227 ++ .../IoTDBHistoryRootDatasetPushConsumerIT.java | 175 ++ .../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 178 ++ .../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 164 ++ .../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 180 ++ ...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 180 ++ .../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 181 ++ .../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 199 ++ .../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 142 + .../regression/topic/IoTDBTestTopicNameIT.java | 139 + .../regression/user/IoTDBOtherUserConsumerIT.java | 143 + iotdb-client/client-cpp/README.md | 17 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 15 +- iotdb-core/ainode/.gitignore | 11 + .../pom.xml => iotdb-core/ainode/README.md | 21 +- .../pom.xml => iotdb-core/ainode/README_ZH.md | 21 +- iotdb-core/ainode/ainode.xml | 62 + iotdb-core/ainode/iotdb/__init__.py | 17 + iotdb-core/ainode/iotdb/ainode/__init__.py | 17 + iotdb-core/ainode/iotdb/ainode/attribute.py | 669 +++++ iotdb-core/ainode/iotdb/ainode/client.py | 285 ++ iotdb-core/ainode/iotdb/ainode/config.py | 276 ++ iotdb-core/ainode/iotdb/ainode/constant.py | 247 ++ iotdb-core/ainode/iotdb/ainode/encryption.py | 17 + iotdb-core/ainode/iotdb/ainode/exception.py | 123 + iotdb-core/ainode/iotdb/ainode/factory.py | 272 ++ iotdb-core/ainode/iotdb/ainode/handler.py | 118 + iotdb-core/ainode/iotdb/ainode/inference.py | 165 ++ iotdb-core/ainode/iotdb/ainode/log.py | 134 + iotdb-core/ainode/iotdb/ainode/parser.py | 191 ++ iotdb-core/ainode/iotdb/ainode/script.py | 102 + iotdb-core/ainode/iotdb/ainode/serde.py | 564 ++++ iotdb-core/ainode/iotdb/ainode/service.py | 139 + iotdb-core/ainode/iotdb/ainode/storage.py | 318 +++ iotdb-core/ainode/iotdb/ainode/util.py | 79 + iotdb-core/ainode/pom.xml | 347 +++ iotdb-core/ainode/pyproject.toml | 66 + iotdb-core/ainode/resources/conf/ainode-env.bat | 128 + iotdb-core/ainode/resources/conf/ainode-env.sh | 138 + .../ainode/resources/conf/iotdb-ainode.properties | 60 + iotdb-core/ainode/resources/sbin/remove-ainode.bat | 107 + iotdb-core/ainode/resources/sbin/remove-ainode.sh | 112 + iotdb-core/ainode/resources/sbin/start-ainode.bat | 77 + iotdb-core/ainode/resources/sbin/start-ainode.sh | 78 + iotdb-core/ainode/resources/sbin/stop-ainode.bat | 61 + iotdb-core/ainode/resources/sbin/stop-ainode.sh | 73 + .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 7 + .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 43 + .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 28 + iotdb-core/confignode/pom.xml | 5 + .../async/AsyncAINodeHeartbeatClientPool.java | 62 + .../handlers/heartbeat/AINodeHeartbeatHandler.java | 57 + .../iotdb/confignode/conf/ConfigNodeConstant.java | 1 + .../consensus/request/ConfigPhysicalPlan.java | 4 + .../consensus/request/ConfigPhysicalPlanType.java | 16 +- .../read/ainode/GetAINodeConfigurationPlan.java | 74 + .../request/read/model/GetModelInfoPlan.java | 80 + .../request/read/model/ShowModelPlan.java | 90 + .../request/write/ainode/RegisterAINodePlan.java | 76 + .../request/write/ainode/RemoveAINodePlan.java | 79 + .../request/write/ainode/UpdateAINodePlan.java | 79 + .../request/write/model/CreateModelPlan.java | 79 + .../request/write/model/DropModelInNodePlan.java | 70 + .../request/write/model/DropModelPlan.java | 79 + .../request/write/model/UpdateModelInfoPlan.java | 118 + .../write/table/SetTablePropertiesPlan.java | 79 + .../response/ainode/AINodeConfigurationResp.java} | 45 +- .../response/ainode/AINodeRegisterResp.java} | 51 +- .../consensus/response/model/GetModelInfoResp.java | 71 + .../consensus/response/model/ModelTableResp.java | 55 + .../statemachine/ConfigRegionStateMachine.java | 65 +- .../iotdb/confignode/manager/ConfigManager.java | 142 +- .../apache/iotdb/confignode/manager/IManager.java | 67 + .../iotdb/confignode/manager/ModelManager.java | 126 + .../iotdb/confignode/manager/ProcedureManager.java | 311 ++- .../iotdb/confignode/manager/load/LoadManager.java | 6 +- .../manager/load/cache/AbstractLoadCache.java | 2 +- .../confignode/manager/load/cache/LoadCache.java | 18 +- ...artbeatCache.java => AINodeHeartbeatCache.java} | 49 +- .../load/cache/node/DataNodeHeartbeatCache.java | 2 +- .../load/cache/node/NodeHeartbeatSample.java | 15 +- .../manager/load/service/HeartbeatService.java | 35 + .../manager/node/ClusterNodeStartUtils.java | 49 + .../iotdb/confignode/manager/node/NodeManager.java | 154 ++ .../client/IoTDBConfigNodeSyncClientManager.java | 6 +- .../protocol/IoTDBConfigRegionAirGapConnector.java | 2 + .../protocol/IoTDBConfigRegionConnector.java | 6 +- .../manager/schema/ClusterSchemaManager.java | 91 +- .../iotdb/confignode/persistence/ModelInfo.java | 382 +++ .../persistence/executor/ConfigPlanExecutor.java | 48 +- .../confignode/persistence/node/NodeInfo.java | 178 ++ .../persistence/schema/ClusterSchemaInfo.java | 30 +- .../confignode/persistence/schema/ConfigMTree.java | 71 +- .../procedure/env/RegionMaintainHandler.java | 49 +- .../procedure/impl/model/CreateModelProcedure.java | 250 ++ .../procedure/impl/model/DropModelProcedure.java | 196 ++ .../procedure/impl/node/RemoveAINodeProcedure.java | 160 ++ .../impl/region/RemoveRegionPeerProcedure.java | 23 +- .../procedure/impl/schema/SchemaUtils.java | 70 + .../impl/schema/table/AddTableColumnProcedure.java | 145 +- .../impl/schema/table/CreateTableProcedure.java | 130 +- .../schema/table/SetTablePropertiesProcedure.java | 325 +++ .../procedure/state/RemoveAINodeState.java | 7 +- .../procedure/state/model/CreateModelState.java | 7 +- .../procedure/state/model/DropModelState.java | 7 +- .../state/schema/SetTablePropertiesState.java | 9 +- .../procedure/store/ProcedureFactory.java | 24 + .../confignode/procedure/store/ProcedureType.java | 6 + .../thrift/ConfigNodeRPCServiceProcessor.java | 78 + .../request/ConfigPhysicalPlanSerDeTest.java | 16 + .../table/SetTablePropertiesProcedureTest.java | 63 + .../org/apache/iotdb/consensus/IConsensus.java | 4 +- .../org/apache/iotdb/consensus/IStateMachine.java | 7 +- .../apache/iotdb/consensus/iot/IoTConsensus.java | 3 +- .../consensus/iot/IoTConsensusServerImpl.java | 5 +- .../service/IoTConsensusRPCServiceProcessor.java | 3 +- .../ratis/ApplicationStateMachineProxy.java | 6 + .../apache/iotdb/consensus/ratis/RatisClient.java | 82 + .../iotdb/consensus/ratis/RatisConsensus.java | 68 +- .../iotdb/consensus/simple/SimpleConsensus.java | 3 +- iotdb-core/datanode/pom.xml | 5 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 89 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 127 +- .../dataregion/DataRegionStateMachine.java | 11 +- .../schemaregion/SchemaExecutionVisitor.java | 26 +- .../schemaregion/SchemaRegionStateMachine.java | 29 +- .../db/exception/ainode/GetModelInfoException.java | 15 +- .../iotdb/db/exception/ainode/ModelException.java | 22 +- .../exception/ainode/ModelNotFoundException.java | 15 +- .../table/TableAlreadyExistsException.java | 2 +- .../metadata/table/TableNotExistsException.java | 2 +- .../runtime/ModelInferenceProcessException.java | 9 +- .../iotdb/db/exception/sql/SemanticException.java | 8 + .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 15 + .../client/IoTDBDataNodeAsyncClientManager.java | 32 +- .../client/IoTDBDataNodeSyncClientManager.java | 6 +- .../evolvable/batch/PipeTabletEventBatch.java | 19 +- .../batch/PipeTransferBatchReqBuilder.java | 5 + .../request/PipeTransferTabletRawReq.java | 1 + .../airgap/IoTDBDataNodeAirGapConnector.java | 2 + .../async/IoTDBDataRegionAsyncConnector.java | 9 +- .../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +- .../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 + .../scan/TsFileInsertionScanDataContainer.java | 134 +- .../pipeconsensus/PipeConsensusReceiver.java | 61 +- .../protocol/thrift/IoTDBDataNodeReceiver.java | 32 +- ...peStatementDataTypeConvertExecutionVisitor.java | 54 +- .../visitor/PipeStatementExceptionVisitor.java | 2 +- .../visitor/PipeStatementPatternParseVisitor.java | 12 + .../visitor/PipeStatementTSStatusVisitor.java | 4 +- .../visitor/PipeStatementToBatchVisitor.java | 28 +- ...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 21 +- .../subtask/connector/PipeConnectorSubtask.java | 5 +- .../connector/PipeConnectorSubtaskLifeCycle.java | 2 +- .../iotdb/db/protocol/client/ConfigNodeClient.java | 89 +- .../v1/handler/StatementConstructionHandler.java | 1 + .../v2/handler/StatementConstructionHandler.java | 2 + .../iotdb/db/protocol/session/IClientSession.java | 8 +- .../handler/AINodeRPCServiceThriftHandler.java | 60 + .../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 ++ .../protocol/thrift/impl/ClientRPCServiceImpl.java | 13 +- .../impl/DataNodeInternalRPCServiceImpl.java | 4 +- .../thrift/impl/IAINodeRPCServiceWithHandler.java | 8 +- .../iotdb/db/queryengine/common/SessionInfo.java | 27 +- .../common/header/ColumnHeaderConstant.java | 22 + .../common/header/DatasetHeaderFactory.java | 8 + .../execution/exchange/source/SourceHandle.java | 12 + .../execution/executor/RegionExecutionResult.java | 21 +- .../execution/executor/RegionReadExecutor.java | 42 +- .../execution/executor/RegionWriteExecutor.java | 137 +- .../fragment/FragmentInstanceContext.java | 10 +- .../fragment/FragmentInstanceManager.java | 11 + .../operator/process/AI/InferenceOperator.java | 337 +++ .../operator/process/FilterAndProjectOperator.java | 6 +- .../operator/schema/SchemaCountOperator.java | 4 +- .../operator/schema/SchemaQueryScanOperator.java | 73 +- .../schema/source/DeviceAttributeUpdater.java | 158 ++ .../schema/source/DevicePredicateFilter.java | 69 + .../schema/source/DevicePredicateHandler.java | 132 + .../schema/source/SchemaSourceFactory.java | 21 +- .../schema/source/TableDeviceQuerySource.java | 100 +- .../execution/operator/source/FileLoaderUtils.java | 18 + .../execution/operator/source/SeriesScanUtil.java | 16 +- .../ainode/BottomInferenceWindowParameter.java | 72 + .../window/ainode/CountInferenceWindow.java} | 27 +- .../ainode/CountInferenceWindowParameter.java | 82 + .../window/ainode/HeadInferenceWindow.java | 20 +- .../operator/window/ainode/InferenceWindow.java | 19 +- .../window/ainode/InferenceWindowParameter.java | 63 + .../window/ainode/InferenceWindowType.java | 9 +- .../window/ainode/TailInferenceWindow.java | 21 +- .../relational/ColumnTransformerBuilder.java | 310 ++- .../execution/schedule/AbstractDriverThread.java | 10 +- .../iotdb/db/queryengine/plan/Coordinator.java | 4 + .../db/queryengine/plan/analyze/Analysis.java | 19 + .../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 184 +- .../db/queryengine/plan/analyze/IModelFetcher.java | 9 +- .../plan/analyze/LoadTsFileAnalyzer.java | 4 +- .../db/queryengine/plan/analyze/ModelFetcher.java | 81 + .../plan/analyze/schema/SchemaValidator.java | 2 +- .../queryengine/plan/execution/QueryExecution.java | 12 + .../execution/config/TableConfigTaskVisitor.java | 119 +- .../execution/config/TreeConfigTaskVisitor.java | 35 +- .../config/executor/ClusterConfigTaskExecutor.java | 162 +- .../config/executor/IConfigTaskExecutor.java | 42 +- .../config/metadata/ShowClusterDetailsTask.java | 62 + .../execution/config/metadata/ShowClusterTask.java | 15 + .../CreateModelTask.java} | 25 +- .../DropModelTask.java} | 21 +- .../config/metadata/model/ShowAINodesTask.java | 80 + .../config/metadata/model/ShowModelsTask.java | 112 + .../relational/AlterTableAddColumnTask.java | 70 +- ...eTask.java => AlterTableSetPropertiesTask.java} | 31 +- .../metadata/relational/CreateTableTask.java | 4 +- .../TableModelStatementMemorySourceVisitor.java | 34 +- .../multi/builtin/helper/CastFunctionHelper.java | 6 +- .../db/queryengine/plan/parser/ASTVisitor.java | 101 + .../plan/parser/StatementGenerator.java | 5 + .../plan/planner/LogicalPlanBuilder.java | 14 + .../plan/planner/LogicalPlanVisitor.java | 8 +- .../plan/planner/OperatorTreeGenerator.java | 47 + .../plan/planner/TableOperatorGenerator.java | 94 +- .../plan/planner/plan/node/PlanNodeType.java | 17 +- .../plan/planner/plan/node/PlanVisitor.java | 21 +- .../plan/node/load/LoadTsFilePieceNode.java | 2 +- .../read/AbstractTableDeviceQueryNode.java | 7 +- .../read/TableDeviceAttributeUpdateNode.java | 355 +++ .../node/metadata/read/TableDeviceFetchNode.java | 6 - .../metadata/read/TableDeviceQueryCountNode.java | 8 + .../metadata/read/TableDeviceQueryScanNode.java | 40 +- .../node/metadata/write/CreateTimeSeriesNode.java | 4 +- .../plan/node/metadata/write/MeasurementGroup.java | 8 +- .../plan/node/process/AI/InferenceNode.java | 133 + .../planner/plan/node/write/InsertRowsNode.java | 4 + .../plan/node/write/RelationalInsertRowsNode.java | 4 + .../parameter/model/ModelInferenceDescriptor.java | 204 ++ .../plan/relational/analyzer/Analysis.java | 4 +- .../relational/analyzer/StatementAnalyzer.java | 209 +- .../schema/CheckSchemaPredicateVisitor.java | 28 +- .../schema/ExtractPredicateColumnNameVisitor.java | 31 +- .../plan/relational/metadata/MetadataUtil.java | 8 +- .../relational/metadata/TableMetadataImpl.java | 310 ++- .../metadata/fetcher/SchemaPredicateUtil.java | 5 +- .../metadata/fetcher/TableDeviceSchemaFetcher.java | 146 +- .../fetcher/TableDeviceSchemaValidator.java | 133 +- .../fetcher/TableHeaderSchemaValidator.java | 115 +- .../fetcher/cache/TableDeviceCacheEntry.java | 19 +- .../fetcher/cache/TableDeviceSchemaCache.java | 39 +- .../plan/relational/planner/LogicalPlanner.java | 111 +- .../plan/relational/planner/TranslationMap.java | 19 + .../distribute/TableModelQueryFragmentPlanner.java | 5 +- .../TableModelTypeProviderExtractor.java | 24 + .../relational/planner/ir/ExpressionRewriter.java | 5 + .../planner/ir/ExpressionTreeRewriter.java | 23 + .../plan/relational/planner/ir/IrVisitor.java | 5 + .../relational/planner/ir/RewritingVisitor.java | 19 + .../rule/MergeLimitOverProjectWithMergeSort.java | 4 +- .../rule/MergeLimitOverProjectWithSort.java | 16 +- .../iterative/rule/MergeLimitWithMergeSort.java | 8 +- .../planner/iterative/rule/MergeLimitWithSort.java | 13 +- ...ode.java => CreateOrUpdateTableDeviceNode.java} | 38 +- .../sql/ast/AbstractQueryDeviceWithCache.java | 91 + ...ueryDevice.java => AbstractTraverseDevice.java} | 130 +- .../plan/relational/sql/ast/AddColumn.java | 59 +- .../plan/relational/sql/ast/AstVisitor.java | 2 +- .../plan/relational/sql/ast/ColumnDefinition.java | 30 +- .../plan/relational/sql/ast/CountDevice.java | 36 +- ...CreateDevice.java => CreateOrUpdateDevice.java} | 6 +- .../plan/relational/sql/ast/CreateTable.java | 28 +- .../sql/ast/DefaultTraversalVisitor.java | 10 +- .../plan/relational/sql/ast/SetProperties.java | 29 +- .../plan/relational/sql/ast/ShowDevice.java | 90 +- .../plan/relational/sql/ast/Update.java | 62 +- .../plan/relational/sql/ast/UpdateAssignment.java | 32 +- .../relational/sql/ast/WrappedInsertStatement.java | 25 +- .../plan/relational/sql/parser/AstBuilder.java | 188 +- .../plan/relational/sql/util/SqlFormatter.java | 26 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 2 +- .../plan/scheduler/load/LoadTsFileScheduler.java | 12 +- .../plan/statement/StatementVisitor.java | 29 +- .../plan/statement/crud/InsertBaseStatement.java | 14 +- .../crud/InsertMultiTabletsStatement.java | 4 +- .../plan/statement/crud/InsertRowStatement.java | 6 +- .../crud/InsertRowsOfOneDeviceStatement.java | 4 +- .../plan/statement/crud/InsertRowsStatement.java | 4 +- .../plan/statement/crud/InsertTabletStatement.java | 2 +- .../plan/statement/crud/QueryStatement.java | 64 + .../metadata/AlterTimeSeriesStatement.java | 26 +- .../metadata/CreateMultiTimeSeriesStatement.java | 2 +- .../metadata/DeleteTimeSeriesStatement.java | 2 +- .../CreateModelStatement.java} | 61 +- .../DropModelStatement.java} | 47 +- .../metadata/model/ShowAINodesStatement.java | 27 +- .../ShowModelsStatement.java} | 55 +- .../binary/CompareBinaryColumnTransformer.java | 3 +- .../column/unary/scalar/AbsColumnTransformer.java | 56 + .../column/unary/scalar/AcosColumnTransformer.java | 53 + .../column/unary/scalar/AsinColumnTransformer.java | 53 + .../column/unary/scalar/AtanColumnTransformer.java | 53 + .../scalar/CastFunctionColumnTransformer.java | 149 +- .../column/unary/scalar/CeilColumnTransformer.java | 53 + .../unary/scalar/Concat2ColumnTransformer.java | 61 + .../unary/scalar/ConcatColumnTransformer.java | 66 + .../unary/scalar/ConcatMultiColumnTransformer.java | 74 + .../column/unary/scalar/CosColumnTransformer.java | 53 + .../column/unary/scalar/CoshColumnTransformer.java | 53 + .../scalar/DateBinFunctionColumnTransformer.java | 158 ++ .../unary/scalar/DegreesColumnTransformer.java | 53 + .../unary/scalar/EndsWith2ColumnTransformer.java | 56 + .../unary/scalar/EndsWithColumnTransformer.java | 52 + .../column/unary/scalar/ExpColumnTransformer.java | 53 + .../unary/scalar/FloorColumnTransformer.java | 53 + .../unary/scalar/LTrim2ColumnTransformer.java | 56 + .../unary/scalar/LTrimColumnTransformer.java | 70 + .../unary/scalar/LengthColumnTransformer.java | 47 + .../column/unary/scalar/LnColumnTransformer.java | 53 + .../unary/scalar/Log10ColumnTransformer.java | 53 + .../unary/scalar/LowerColumnTransformer.java | 47 + .../unary/scalar/RTrim2ColumnTransformer.java | 56 + .../unary/scalar/RTrimColumnTransformer.java | 70 + .../unary/scalar/RadiansColumnTransformer.java | 53 + .../unary/scalar/RegexpLike2ColumnTransformer.java | 54 + .../unary/scalar/RegexpLikeColumnTransformer.java | 52 + .../column/unary/scalar/SignColumnTransformer.java | 53 + .../column/unary/scalar/SinColumnTransformer.java | 53 + .../column/unary/scalar/SinhColumnTransformer.java | 53 + .../column/unary/scalar/SqrtColumnTransformer.java | 53 + .../unary/scalar/StartsWith2ColumnTransformer.java | 55 + .../unary/scalar/StartsWithColumnTransformer.java | 61 + .../unary/scalar/Strcmp2ColumnTransformer.java | 54 + .../unary/scalar/StrcmpColumnTransformer.java | 50 + .../unary/scalar/Strpos2ColumnTransformer.java | 54 + .../unary/scalar/StrposColumnTransformer.java | 50 + .../unary/scalar/TableBuiltinScalarFunction.java | 71 + .../column/unary/scalar/TanColumnTransformer.java | 53 + .../column/unary/scalar/TanhColumnTransformer.java | 53 + .../unary/scalar/Trim2ColumnTransformer.java | 56 + .../column/unary/scalar/TrimColumnTransformer.java | 82 + .../unary/scalar/UpperColumnTransformer.java | 48 + .../schemaengine/schemaregion/ISchemaRegion.java | 16 +- .../schemaregion/SchemaRegionPlanType.java | 4 + .../schemaregion/SchemaRegionPlanVisitor.java | 55 +- .../attribute/DeviceAttributeStore.java | 43 +- .../attribute/IDeviceAttributeStore.java | 13 +- .../schemaregion/impl/SchemaRegionMemoryImpl.java | 567 ++-- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 26 +- .../visitor/SchemaRegionPlanDeserializer.java | 109 +- .../visitor/SchemaRegionPlanSerializer.java | 182 +- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 55 +- .../read/resp/info/impl/ShowDevicesResult.java | 18 + .../write/req/SchemaRegionWritePlanFactory.java | 6 + .../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 16 + .../apache/iotdb/db/service/AINodeRPCService.java | 94 + .../iotdb/db/service/AINodeRPCServiceMBean.java | 4 +- .../java/org/apache/iotdb/db/service/DataNode.java | 4 + .../db/service/metrics/DataNodeMetricsHelper.java | 6 +- .../iotdb/db/storageengine/StorageEngine.java | 4 +- .../db/storageengine/dataregion/DataRegion.java | 4 +- .../BatchCompactionCannotAlignedException.java | 55 + .../performer/impl/FastCompactionPerformer.java | 5 +- .../impl/ReadChunkCompactionPerformer.java | 124 +- .../impl/ReadPointCompactionPerformer.java | 11 +- .../execute/task/CompactionTaskSummary.java | 2 +- .../execute/task/InnerSpaceCompactionTask.java | 571 ++-- .../task/RepairUnsortedFileCompactionTask.java | 65 +- .../execute/task/SettleCompactionTask.java | 105 +- .../subtask/FastCompactionPerformerSubTask.java | 50 +- .../task/subtask/ReadPointPerformerSubTask.java | 4 +- .../execute/utils/CompactionPathUtils.java | 2 +- .../utils/CompactionTableSchemaCollector.java | 13 +- .../compaction/execute/utils/CompactionUtils.java | 19 + ...BatchedFastAlignedSeriesCompactionExecutor.java | 387 +++ ...edReadChunkAlignedSeriesCompactionExecutor.java | 426 +++ .../utils/AlignedSeriesBatchCompactionUtils.java | 176 ++ .../executor/batch/utils/BatchCompactionPlan.java | 68 + .../BatchedCompactionAlignedPagePointReader.java | 95 + .../batch/utils/ChunkWriterFlushCallback.java | 9 +- .../executor/batch/utils/CompactChunkPlan.java | 70 + .../utils/CompactPagePlan.java} | 33 +- .../FirstBatchCompactionAlignedChunkWriter.java | 187 ++ ...FollowingBatchCompactionAlignedChunkWriter.java | 266 ++ ...va => FastAlignedSeriesCompactionExecutor.java} | 241 +- ...=> FastNonAlignedSeriesCompactionExecutor.java} | 38 +- .../executor/fast/SeriesCompactionExecutor.java | 71 +- .../executor/fast/element/AlignedPageElement.java | 22 +- .../fast/element/ChunkMetadataElement.java | 19 +- .../utils/executor/fast/element/FileElement.java | 10 + .../fast/element/NonAlignedPageElement.java | 5 +- .../utils/executor/fast/element/PageElement.java | 18 +- .../utils/executor/fast/element/PointElement.java | 8 +- .../fast/reader/CompactionAlignedChunkReader.java | 29 +- .../ReadChunkAlignedSeriesCompactionExecutor.java | 109 +- .../executor/readchunk/loader/ChunkLoader.java | 8 +- .../readchunk/loader/InstantChunkLoader.java | 7 +- .../readchunk/loader/InstantPageLoader.java | 8 +- .../executor/readchunk/loader/PageLoader.java | 18 +- .../execute/utils/reader/PointPriorityReader.java | 12 +- .../utils/writer/AbstractCompactionWriter.java | 65 +- .../writer/AbstractCrossCompactionWriter.java | 13 +- .../writer/AbstractInnerCompactionWriter.java | 99 +- .../utils/writer/FastCrossCompactionWriter.java | 105 +- .../utils/writer/FastInnerCompactionWriter.java | 103 +- .../writer/ReadPointCrossCompactionWriter.java | 48 +- .../writer/ReadPointInnerCompactionWriter.java | 42 +- .../writer/RepairUnsortedFileCompactionWriter.java | 7 +- .../AbstractCompactionFlushController.java} | 45 +- .../FollowedBatchedCompactionFlushController.java | 68 + .../compaction/io/CompactionTsFileWriter.java | 3 +- .../schedule/CompactionScheduleTaskManager.java | 1 + .../DefaultCompactionTaskComparatorImpl.java | 16 +- .../constant/InnerSequenceCompactionSelector.java | 16 +- .../InnerUnsequenceCompactionSelector.java | 16 +- .../estimator/AbstractCrossSpaceEstimator.java | 3 + .../estimator/AbstractInnerSpaceEstimator.java | 3 + .../estimator/CompactionEstimateUtils.java | 9 + .../FastCompactionInnerCompactionEstimator.java | 23 +- .../FastCrossSpaceCompactionEstimator.java | 27 +- .../ReadChunkInnerCompactionEstimator.java | 21 +- .../RepairUnsortedFileCompactionEstimator.java | 10 + .../impl/NewSizeTieredCompactionSelector.java | 295 +++ .../impl/RewriteCrossSpaceCompactionSelector.java | 14 +- .../selector/impl/SettleSelectorImpl.java | 2 +- .../impl/SizeTieredCompactionSelector.java | 12 +- .../utils/CrossSpaceCompactionCandidate.java | 2 +- .../selector/utils/TsFileResourceCandidate.java | 11 +- .../compaction/settle/SettleRequestHandler.java | 2 +- .../read/reader/chunk/DiskAlignedChunkLoader.java | 5 + .../read/reader/chunk/DiskChunkLoader.java | 5 + .../dataregion/read/reader/common/Element.java | 9 +- .../read/reader/common/MergeReaderPriority.java | 73 + .../read/reader/common/PriorityMergeReader.java | 49 +- .../dataregion/snapshot/SnapshotTaker.java | 34 +- .../storageengine/dataregion/tsfile/TsFileID.java | 34 +- .../dataregion/tsfile/TsFileResource.java | 6 +- .../tsfile/generator/TsFileNameGenerator.java | 34 + .../dataregion/utils/TsFileResourceUtils.java | 22 +- .../load/LoadTsFileManager.java | 22 +- .../storageengine/load/active/ActiveLoadAgent.java | 51 + .../load/active/ActiveLoadDirScanner.java | 77 +- .../load/active/ActiveLoadMetricsCollector.java | 96 + .../load/active/ActiveLoadPendingQueue.java | 11 +- .../active/ActiveLoadScheduledExecutorService.java | 107 + .../load/active/ActiveLoadTsFileLoader.java | 79 +- .../load/limiter/LoadTsFileRateLimiter.java | 4 +- .../memory}/LoadTsFileAbstractMemoryBlock.java | 2 +- .../LoadTsFileAnalyzeSchemaMemoryBlock.java | 4 +- .../memory}/LoadTsFileDataCacheMemoryBlock.java | 2 +- .../load/memory}/LoadTsFileMemoryManager.java | 2 +- .../load/metrics/ActiveLoadingFilesMetricsSet.java | 113 + .../load/metrics}/LoadTsFileCostMetricsSet.java | 2 +- .../load/metrics}/LoadTsFileMemMetricSet.java | 4 +- .../load/splitter/AlignedChunkData.java | 74 +- .../splitter/BatchedAlignedValueChunkData.java | 237 ++ .../load/splitter/ChunkData.java | 2 +- .../load/splitter/DeletionData.java | 2 +- .../load/splitter/NonAlignedChunkData.java | 2 +- .../load/splitter/TsFileData.java | 2 +- .../load/splitter/TsFileSplitter.java | 469 ++-- .../rescon/quotas/DataNodeSpaceQuotaManager.java | 89 +- .../apache/iotdb/db/tools/schema/MLogParser.java | 1 + .../org/apache/iotdb/db/utils/DateTimeUtils.java | 40 +- .../SchemaRegionSimpleRecoverTest.java | 81 + .../schemaRegion/SchemaRegionTableDeviceTest.java | 74 +- .../schemaRegion/SchemaRegionTestUtil.java | 36 +- .../PipeStatementPatternParseVisitorTest.java | 54 +- .../event/TsFileInsertionDataContainerTest.java | 553 +--- .../extractor/PipePlanPatternParseVisitorTest.java | 104 +- .../plan/relational/analyzer/SortTest.java | 141 +- .../fetcher/cache/TableDeviceSchemaCacheTest.java | 40 +- .../column/unary/scalar/DateBinFunctionTest.java | 101 + .../storageengine/dataregion/DataRegionTest.java | 22 +- .../compaction/AbstractCompactionTest.java | 101 + .../BatchedCompactionWithTsFileSplitterTest.java | 350 +++ .../compaction/CompactionSchedulerTest.java | 96 +- .../CompactionSchedulerWithFastPerformerTest.java | 96 +- .../FastCompactionPerformerWithEmptyPageTest.java | 8 + ...InconsistentCompressionTypeAndEncodingTest.java | 13 +- ...tchedAlignedSeriesCrossSpaceCompactionTest.java | 510 ++++ ...eCompactionWithFastPerformerValidationTest.java | 18 +- ...actionWithReadPointPerformerValidationTest.java | 16 +- .../cross/RewriteCompactionFileSelectorTest.java | 6 + ...atchedAlignedSeriesFastInnerCompactionTest.java | 415 +++ ...tchedAlignedSeriesReadChunkCompactionTest.java} | 503 ++-- .../inner/FastCompactionPerformerAlignedTest.java | 64 +- .../FastCompactionPerformerNoAlignedTest.java | 36 +- .../inner/InnerCompactionSchedulerTest.java | 10 +- .../inner/InnerSequenceCompactionSpeedTest.java | 4 +- .../inner/InnerSpaceCompactionSelectorTest.java | 2 +- ...nkCompactionPerformerWithAlignedSeriesTest.java | 456 ++-- .../ReadChunkCompactionPerformerAlignedTest.java | 64 +- .../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +- .../NewSizeTieredCompactionSelectorTest.java | 644 +++++ .../repair/RepairUnsortedFileCompactionTest.java | 306 --- .../repair/RepairUnsortedFileSchedulerTest.java | 384 +++ .../settle/SettleCompactionSelectorTest.java | 32 +- .../settle/SettleCompactionTaskTest.java | 4 +- .../settle/SettleRequestHandlerTest.java | 6 +- .../compaction/utils/BatchCompactionUtilsTest.java | 293 +++ .../compaction/utils/CompactionCheckerUtils.java | 130 +- .../compaction/utils/CompactionConfigRestorer.java | 4 +- .../compaction/utils/CompactionTestFileWriter.java | 39 +- .../compaction/utils/MergeReaderPriorityTest.java | 96 + iotdb-core/node-commons/pom.xml | 6 + .../conf/iotdb-system.properties.template | 39 +- .../iotdb/commons/client/ClientPoolFactory.java | 52 + .../iotdb/commons/client/ainode/AINodeClient.java | 237 ++ .../ainode/AINodeClientManager.java} | 30 +- .../iotdb/commons/client/ainode/AINodeInfo.java | 18 +- .../client/ainode/AsyncAINodeServiceClient.java | 143 + .../org/apache/iotdb/commons/cluster/NodeType.java | 3 +- .../iotdb/commons/concurrent/ThreadName.java | 4 + .../apache/iotdb/commons/conf/CommonConfig.java | 26 + .../exception/ainode/LoadModelException.java | 15 +- .../iotdb/commons/model/ModelHyperparameter.java | 81 + .../iotdb/commons/model/ModelInformation.java | 364 +++ .../apache/iotdb/commons/model/ModelStatus.java | 10 +- .../org/apache/iotdb/commons/model/ModelTable.java | 94 + .../org/apache/iotdb/commons/model/ModelType.java | 8 +- .../model/exception/ModelManagementException.java | 8 +- .../iotdb/commons/partition/SchemaPartition.java | 1 + .../org/apache/iotdb/commons/path/PartialPath.java | 9 + .../config/constant/PipeConnectorConstant.java | 11 + .../connector/client/IoTDBSyncClientManager.java | 8 +- .../common/PipeTransferHandshakeConstant.java | 1 + .../pipe/connector/protocol/IoTDBConnector.java | 28 + .../connector/protocol/IoTDBSslSyncConnector.java | 6 +- .../AbstractSerializableListeningQueue.java | 4 +- .../commons/pipe/receiver/IoTDBFileReceiver.java | 14 + .../iotdb/commons/pipe/task/PipeTaskManager.java | 13 + .../iotdb/commons/schema/SchemaConstant.java | 1 + .../schema/table/AlterTableOperationType.java | 9 +- .../apache/iotdb/commons/schema/table/TsTable.java | 20 +- .../schema/table/column/TsTableColumnSchema.java | 4 + .../apache/iotdb/commons/service/ServiceType.java | 1 + .../iotdb/commons/service/metric/enums/Metric.java | 1 + .../org/apache/iotdb/commons/utils/FileUtils.java | 53 + .../commons/utils/ThriftCommonsSerDeUtils.java | 59 + iotdb-core/pom.xml | 8 + .../db/relational/grammar/sql/RelationalSql.g4 | 15 +- iotdb-protocol/pom.xml | 1 + .../thrift-ainode}/pom.xml | 51 +- .../thrift-ainode/src/main/thrift/ainode.thrift | 91 + .../thrift-commons/src/main/thrift/common.thrift | 30 + .../src/main/thrift/confignode.thrift | 128 +- .../src/main/thrift/datanode.thrift | 58 +- pom.xml | 10 +- 728 files changed, 51663 insertions(+), 6437 deletions(-)
