This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch speed_up_recover
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a21917ac870 fix compile issue
add bc924d8de07 fixing review
add de28b7ef466 date_bin scalar function
add 87f765b426f [Fix] Add another retryPolicy for RatisClient (#13286)
add b28374ea69a Enable cpp client CI on Windows-2019 with visual studio
2019 (#13289)
add dc55eb06d32 Update DataNodeSpaceQuotaManager.java
add bc3b4d32c11 Introduce AINode to IoTDB (#13254)
add 7a2a0b4bb2c Fixed the NPE of failed internal create timeseries (#13253)
add e94c2c1ff71 Add subquery UT and IT, Remove some wrong implementation
code
add 02e88066d88 Merge branch 'master' of github.com:apache/iotdb into
speed_up_recover
add d2c0030ba96 fix review
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 12 +-
.../main/java/org/apache/iotdb/it/env/EnvType.java | 2 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 99 +--
.../scalar/IoTDBScalarFunctionTableIT.java | 54 ++
iotdb-client/client-cpp/README.md | 17 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 11 +-
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 ++
.../ainode}/iotdb/__init__.py | 0
.../ainode/iotdb/ainode}/__init__.py | 0
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 ++++++++
.../ainode/iotdb/ainode/encryption.py | 0
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/ConfigPhysicalPlanType.java | 15 +-
.../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 ++++
.../response/ainode/AINodeConfigurationResp.java | 57 ++
.../response/ainode/AINodeRegisterResp.java | 67 +++
.../consensus/response/model/GetModelInfoResp.java | 71 +++
.../consensus/response/model/ModelTableResp.java | 55 ++
.../iotdb/confignode/manager/ConfigManager.java | 140 ++++-
.../apache/iotdb/confignode/manager/IManager.java | 67 +++
.../iotdb/confignode/manager/ModelManager.java | 126 ++++
.../iotdb/confignode/manager/ProcedureManager.java | 30 +
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../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 +++++
.../iotdb/confignode/persistence/ModelInfo.java | 382 ++++++++++++
.../persistence/executor/ConfigPlanExecutor.java | 45 +-
.../confignode/persistence/node/NodeInfo.java | 178 ++++++
.../procedure/impl/model/CreateModelProcedure.java | 250 ++++++++
.../procedure/impl/model/DropModelProcedure.java | 196 ++++++
.../procedure/impl/node/RemoveAINodeProcedure.java | 160 +++++
.../procedure/state/RemoveAINodeState.java | 17 +-
.../procedure/state/model/CreateModelState.java | 17 +-
.../procedure/state/model/DropModelState.java | 17 +-
.../procedure/store/ProcedureFactory.java | 18 +
.../confignode/procedure/store/ProcedureType.java | 5 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 78 +++
.../apache/iotdb/consensus/ratis/RatisClient.java | 28 +-
iotdb-core/datanode/pom.xml | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 +
.../db/exception/ainode/GetModelInfoException.java | 16 +-
.../iotdb/db/exception/ainode/ModelException.java | 23 +-
.../exception/ainode/ModelNotFoundException.java | 16 +-
.../runtime/ModelInferenceProcessException.java | 15 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 64 ++
.../handler/AINodeRPCServiceThriftHandler.java | 60 ++
.../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 ++++++
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../thrift/impl/IAINodeRPCServiceWithHandler.java | 16 +-
.../common/header/ColumnHeaderConstant.java | 22 +
.../common/header/DatasetHeaderFactory.java | 8 +
.../fragment/FragmentInstanceManager.java | 11 +
.../operator/process/AI/InferenceOperator.java | 337 +++++++++++
.../ainode/BottomInferenceWindowParameter.java | 72 +++
.../window/ainode/CountInferenceWindow.java | 28 +-
.../ainode/CountInferenceWindowParameter.java | 82 +++
.../window/ainode/HeadInferenceWindow.java | 21 +-
.../operator/window/ainode/InferenceWindow.java | 20 +-
.../window/ainode/InferenceWindowParameter.java | 63 ++
.../window/ainode/InferenceWindowType.java | 19 +-
.../window/ainode/TailInferenceWindow.java | 22 +-
.../relational/ColumnTransformerBuilder.java | 12 +
.../db/queryengine/plan/analyze/Analysis.java | 19 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 176 ++++++
.../db/queryengine/plan/analyze/IModelFetcher.java | 17 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 81 +++
.../analyze/schema/AutoCreateSchemaExecutor.java | 20 +-
.../execution/config/TreeConfigTaskVisitor.java | 33 +
.../config/executor/ClusterConfigTaskExecutor.java | 95 ++-
.../config/executor/IConfigTaskExecutor.java | 11 +
.../config/metadata/ShowClusterDetailsTask.java | 62 ++
.../execution/config/metadata/ShowClusterTask.java | 15 +
.../config/metadata/model/CreateModelTask.java | 45 ++
.../config/metadata/model/DropModelTask.java} | 31 +-
.../config/metadata/model/ShowAINodesTask.java | 80 +++
.../config/metadata/model/ShowModelsTask.java | 112 ++++
.../db/queryengine/plan/parser/ASTVisitor.java | 101 ++++
.../plan/parser/StatementGenerator.java | 5 +
.../plan/planner/LogicalPlanBuilder.java | 14 +
.../plan/planner/LogicalPlanVisitor.java | 4 +
.../plan/planner/OperatorTreeGenerator.java | 47 ++
.../plan/planner/plan/node/PlanNodeType.java | 7 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/process/AI/InferenceNode.java | 133 ++++
.../parameter/model/ModelInferenceDescriptor.java | 204 +++++++
.../relational/metadata/TableMetadataImpl.java | 18 +-
.../plan/relational/planner/PredicateUtils.java | 217 -------
.../iterative/rule/PushLimitThroughProject.java | 9 +
.../PushLimitOffsetIntoTableScan.java | 188 ++----
.../planner/optimizations/SortElimination.java | 7 +-
.../optimizations/TransformSortToStreamSort.java | 18 +
.../plan/relational/sql/parser/AstBuilder.java | 30 +
.../plan/statement/StatementVisitor.java | 21 +
.../plan/statement/crud/QueryStatement.java | 64 ++
.../metadata/model/CreateModelStatement.java | 85 +++
.../metadata/model/DropModelStatement.java | 71 +++
.../metadata/model/ShowAINodesStatement.java} | 30 +-
.../metadata/model/ShowModelsStatement.java | 79 +++
.../scalar/DateBinFunctionColumnTransformer.java | 158 +++++
.../unary/scalar/TableBuiltinScalarFunction.java | 1 +
.../apache/iotdb/db/service/AINodeRPCService.java | 94 +++
.../iotdb/db/service/AINodeRPCServiceMBean.java | 16 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../iotdb/db/storageengine/StorageEngine.java | 12 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../dataregion/DeviceLastFlushTime.java | 4 +
.../dataregion/HashLastFlushTimeMap.java | 26 +-
.../schedule/CompactionScheduleTaskWorker.java | 2 +-
.../compaction/schedule/TTLScheduleTask.java | 2 +-
.../dataregion/tsfile/TsFileResource.java | 6 +
.../timeindex/FileTimeIndexCacheRecorder.java | 48 +-
.../FileTimeIndexCacheReader.java | 4 +-
.../rescon/quotas/DataNodeSpaceQuotaManager.java | 89 ++-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 2 +-
.../analyzer/LimitOffsetPushDownTest.java | 16 +
.../plan/relational/analyzer/SortTest.java | 94 +--
.../plan/relational/analyzer/SubQueryTest.java | 477 +++++++++++++++
.../planner/assertions/OffsetMatcher.java | 6 +
.../relational/planner/assertions/PlanAssert.java | 3 +-
.../planner/assertions/PlanMatchPattern.java | 5 +
.../column/unary/scalar/DateBinFunctionTest.java | 101 ++++
iotdb-core/node-commons/pom.xml | 6 +
.../iotdb/commons/client/ClientPoolFactory.java | 52 ++
.../iotdb/commons/client/ainode/AINodeClient.java | 237 ++++++++
.../ainode/AINodeClientManager.java} | 30 +-
.../iotdb/commons/client/ainode/AINodeInfo.java | 19 +-
.../client/ainode/AsyncAINodeServiceClient.java | 143 +++++
.../org/apache/iotdb/commons/cluster/NodeType.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 26 +
.../exception/ainode/LoadModelException.java | 16 +-
.../iotdb/commons/model/ModelHyperparameter.java | 81 +++
.../iotdb/commons/model/ModelInformation.java | 364 +++++++++++
.../apache/iotdb/commons/model/ModelStatus.java | 20 +-
.../org/apache/iotdb/commons/model/ModelTable.java | 94 +++
.../org/apache/iotdb/commons/model/ModelType.java | 18 +-
.../model/exception/ModelManagementException.java | 16 +-
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../commons/utils/ThriftCommonsSerDeUtils.java | 59 ++
iotdb-core/pom.xml | 8 +
.../db/relational/grammar/sql/RelationalSql.g4 | 2 +
iotdb-protocol/pom.xml | 1 +
iotdb-protocol/thrift-ainode/pom.xml | 69 +++
.../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 | 2 +-
198 files changed, 13716 insertions(+), 965 deletions(-)
create mode 100644 iotdb-core/ainode/.gitignore
copy iotdb-protocol/pom.xml => iotdb-core/ainode/README.md (51%)
copy iotdb-protocol/pom.xml => iotdb-core/ainode/README_ZH.md (51%)
create mode 100644 iotdb-core/ainode/ainode.xml
copy {iotdb-client/client-py => iotdb-core/ainode}/iotdb/__init__.py (100%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode}/__init__.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/attribute.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/client.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/config.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/constant.py
copy iotdb-client/client-py/iotdb/__init__.py =>
iotdb-core/ainode/iotdb/ainode/encryption.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/exception.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/factory.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/handler.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/inference.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/log.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/parser.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/script.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/serde.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/service.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/storage.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/util.py
create mode 100644 iotdb-core/ainode/pom.xml
create mode 100644 iotdb-core/ainode/pyproject.toml
create mode 100644 iotdb-core/ainode/resources/conf/ainode-env.bat
create mode 100644 iotdb-core/ainode/resources/conf/ainode-env.sh
create mode 100644 iotdb-core/ainode/resources/conf/iotdb-ainode.properties
create mode 100644 iotdb-core/ainode/resources/sbin/remove-ainode.bat
create mode 100755 iotdb-core/ainode/resources/sbin/remove-ainode.sh
create mode 100644 iotdb-core/ainode/resources/sbin/start-ainode.bat
create mode 100644 iotdb-core/ainode/resources/sbin/start-ainode.sh
create mode 100644 iotdb-core/ainode/resources/sbin/stop-ainode.bat
create mode 100644 iotdb-core/ainode/resources/sbin/stop-ainode.sh
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncAINodeHeartbeatClientPool.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/heartbeat/AINodeHeartbeatHandler.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/ainode/GetAINodeConfigurationPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/GetModelInfoPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/ShowModelPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ainode/RegisterAINodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ainode/RemoveAINodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ainode/UpdateAINodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/CreateModelPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/DropModelInNodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/DropModelPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/UpdateModelInfoPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ainode/AINodeConfigurationResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ainode/AINodeRegisterResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/model/GetModelInfoResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/model/ModelTableResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/{DataNodeHeartbeatCache.java
=> AINodeHeartbeatCache.java} (60%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ModelInfo.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/DropModelProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveAINodeProcedure.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RemoveAINodeState.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/CreateModelState.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/DropModelState.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/GetModelInfoException.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelException.java
(70%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelNotFoundException.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/ModelInferenceProcessException.java
(73%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/handler/AINodeRPCServiceThriftHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/AINodeRPCServiceImpl.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/IAINodeRPCServiceWithHandler.java
(73%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AI/InferenceOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/BottomInferenceWindowParameter.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/CountInferenceWindow.java
(64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/CountInferenceWindowParameter.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/HeadInferenceWindow.java
(70%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/InferenceWindow.java
(73%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/InferenceWindowParameter.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/InferenceWindowType.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/TailInferenceWindow.java
(70%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/IModelFetcher.java
(73%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ModelFetcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/CreateModelTask.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeType.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/DropModelTask.java}
(52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowAINodesTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowModelsTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/AI/InferenceNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/parameter/model/ModelInferenceDescriptor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateModelStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/DropModelStatement.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeType.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowAINodesStatement.java}
(54%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowModelsStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DateBinFunctionColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCService.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCServiceMBean.java
(73%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SubQueryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DateBinFunctionTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{cluster/NodeType.java
=> client/ainode/AINodeClientManager.java} (54%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeInfo.java
(70%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AsyncAINodeServiceClient.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/ainode/LoadModelException.java
(73%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelInformation.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelStatus.java
(73%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelTable.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelType.java
(73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/exception/ModelManagementException.java
(73%)
create mode 100644 iotdb-protocol/thrift-ainode/pom.xml
create mode 100644 iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift
