This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch rc/2.0.6
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard fbbc6750c6e [AINode][To rc/2.0.6] cp AINode codes (#16910)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/rc/2.0.6 (460f3e90bb0)
\
O -- O -- O (fbbc6750c6e)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d1a.yml | 5 +-
integration-test/src/assembly/mpp-test.xml | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 27 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 181 --
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 4 +-
.../ainode/it/AINodeInstanceManagementIT.java | 212 --
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 35 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 -
iotdb-core/ainode/.flake8 | 33 -
iotdb-core/ainode/.gitignore | 11 +-
iotdb-core/ainode/ainode.spec | 199 --
iotdb-core/ainode/ainode.xml | 17 +-
.../ainode/{iotdb/thrift => ainode}/__init__.py | 0
.../{iotdb/ainode => ainode/core}/__init__.py | 0
.../ainode/{iotdb => }/ainode/core/ai_node.py | 29 +-
.../ainode/{iotdb => }/ainode/core/config.py | 107 +-
.../ainode/{iotdb => }/ainode/core/constant.py | 35 +-
.../ainode/{iotdb => }/ainode/core/exception.py | 9 +-
.../core => ainode/core/inference}/__init__.py | 0
.../ainode/core/inference/inference_request.py | 18 +-
.../core/inference/inference_request_pool.py | 197 ++
.../core/inference/scheduler}/__init__.py | 0
.../inference/scheduler/abstract_scheduler.py} | 2 +-
.../core/inference/scheduler/basic_scheduler.py} | 11 +-
.../core/inference/strategy}/__init__.py | 0
.../strategy/abstract_inference_pipeline.py | 0
.../strategy/timer_sundial_inference_pipeline.py | 6 +-
.../strategy/timerxl_inference_pipeline.py | 12 +-
.../{iotdb => }/ainode/core/inference/utils.py | 0
.../dispatcher => ainode/core/ingress}/__init__.py | 0
.../{iotdb => }/ainode/core/ingress/dataset.py | 0
.../{iotdb => }/ainode/core/ingress/iotdb.py | 22 +-
iotdb-core/ainode/{iotdb => }/ainode/core/log.py | 8 +-
.../core/manager}/__init__.py | 0
.../ainode/core/manager/cluster_manager.py | 7 +-
.../ainode/core/manager/inference_manager.py | 254 +-
.../ainode/core/manager/model_manager.py | 38 +-
.../{iotdb => }/ainode/core/manager/utils.py | 35 +-
.../core/model}/__init__.py | 0
.../ainode/core/model/built_in_model_factory.py | 54 +-
.../{iotdb => }/ainode/core/model/model_enums.py | 0
.../{iotdb => }/ainode/core/model/model_factory.py | 14 +-
.../{iotdb => }/ainode/core/model/model_info.py | 4 +-
.../{iotdb => }/ainode/core/model/model_storage.py | 37 +-
.../core/model/sundial}/__init__.py | 0
.../core/model/sundial/configuration_sundial.py | 0
.../ainode/core/model/sundial/flow_loss.py | 0
.../ainode/core/model/sundial/modeling_sundial.py | 23 +-
.../core/model/sundial/ts_generation_mixin.py | 0
.../core/model/timerxl}/__init__.py | 0
.../core/model/timerxl/configuration_timer.py | 0
.../ainode/core/model/timerxl/modeling_timer.py | 12 +-
.../core/model/timerxl/ts_generation_mixin.py | 0
.../{iotdb => }/ainode/core/model/uri_utils.py | 10 +-
.../core/manager => ainode/core/rpc}/__init__.py | 0
.../ainode/{iotdb => }/ainode/core/rpc/client.py | 65 +-
iotdb-core/ainode/ainode/core/rpc/handler.py | 76 +
.../ainode/{iotdb => }/ainode/core/rpc/service.py | 42 +-
.../ainode/{iotdb => }/ainode/core/rpc/status.py | 6 +-
iotdb-core/ainode/ainode/core/script.py | 110 +
.../core/model => ainode/core/util}/__init__.py | 0
.../{iotdb => }/ainode/core/util/activation.py | 0
.../ainode/{iotdb => }/ainode/core/util/cache.py | 4 +-
.../{iotdb => }/ainode/core/util/decorator.py | 15 -
.../ainode/core/util/huggingface_cache.py | 0
.../ainode/{iotdb => }/ainode/core/util/lock.py | 0
.../ainode/{iotdb => }/ainode/core/util/masking.py | 0
.../ainode/{iotdb => }/ainode/core/util/serde.py | 2 +-
iotdb-core/ainode/build_binary.py | 602 -----
iotdb-core/ainode/iotdb/Session.py | 33 +-
iotdb-core/ainode/iotdb/ainode/conf/git.properties | 3 +
.../ainode/conf}/pom.properties | 2 +-
.../core/inference/batcher/abstract_batcher.py | 42 -
.../ainode/core/inference/batcher/basic_batcher.py | 63 -
.../inference/dispatcher/abstract_dispatcher.py | 43 -
.../core/inference/dispatcher/basic_dispatcher.py | 60 -
.../core/inference/inference_request_pool.py | 223 --
.../iotdb/ainode/core/inference/pool_controller.py | 519 ----
.../iotdb/ainode/core/inference/pool_group.py | 121 -
.../pool_scheduler/abstract_pool_scheduler.py | 86 -
.../pool_scheduler/basic_pool_scheduler.py | 193 --
.../iotdb/ainode/core/model/sundial/__init__.py | 17 -
.../iotdb/ainode/core/model/timerxl/__init__.py | 17 -
.../ainode/iotdb/ainode/core/rpc/__init__.py | 17 -
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 137 --
iotdb-core/ainode/iotdb/ainode/core/script.py | 69 -
.../ainode/iotdb/ainode/core/util/__init__.py | 17 -
.../ainode/iotdb/ainode/core/util/atmoic_int.py | 66 -
.../iotdb/ainode/core/util/batch_executor.py | 133 -
.../ainode/iotdb/ainode/core/util/gpu_mapping.py | 93 -
.../ainode/iotdb/ainode/core/util/thread_name.py | 22 -
.../ainode/iotdb/sqlalchemy/IoTDBSQLCompiler.py | 3 +-
iotdb-core/ainode/iotdb/table_session_pool.py | 2 +-
.../ainode/iotdb/template/MeasurementNode.py | 5 +-
iotdb-core/ainode/iotdb/template/Template.py | 2 +-
.../iotdb/thrift/ainode/IAINodeRPCService-remote | 6 +-
.../iotdb/thrift/ainode/IAINodeRPCService.py | 18 +-
iotdb-core/ainode/iotdb/thrift/ainode/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/ainode/ttypes.py | 13 +-
iotdb-core/ainode/iotdb/thrift/common/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/common/ttypes.py | 104 +-
.../thrift/confignode/IConfigNodeRPCService-remote | 70 +-
.../thrift/confignode/IConfigNodeRPCService.py | 1684 +++++++++++--
.../ainode/iotdb/thrift/confignode/constants.py | 11 +-
.../ainode/iotdb/thrift/confignode/ttypes.py | 2542 ++++++++++++++------
.../thrift/datanode/IDataNodeRPCService-remote | 31 +-
.../iotdb/thrift/datanode/IDataNodeRPCService.py | 567 ++++-
.../thrift/datanode/MPPDataExchangeService-remote | 6 +-
.../thrift/datanode/MPPDataExchangeService.py | 18 +-
.../ainode/iotdb/thrift/datanode/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/datanode/ttypes.py | 319 ++-
.../iotdb/thrift/rpc/IClientRPCService-remote | 13 +-
.../ainode/iotdb/thrift/rpc/IClientRPCService.py | 207 +-
iotdb-core/ainode/iotdb/thrift/rpc/constants.py | 11 +-
iotdb-core/ainode/iotdb/thrift/rpc/ttypes.py | 231 +-
.../iotdb/tsfile/utils/read_write_io_utils.py | 2 +-
.../ainode/iotdb/tsfile/utils/tsblock_serde.py | 1 +
iotdb-core/ainode/iotdb/utils/Field.py | 8 +-
iotdb-core/ainode/iotdb/utils/IoTDBConstants.py | 3 +-
iotdb-core/ainode/iotdb/utils/NumpyTablet.py | 4 +-
iotdb-core/ainode/iotdb/utils/SessionDataSet.py | 6 +-
iotdb-core/ainode/iotdb/utils/Tablet.py | 2 +-
iotdb-core/ainode/iotdb/utils/iotdb_rpc_dataset.py | 4 +-
iotdb-core/ainode/poetry.lock | 2402 ++++++++++++++++++
iotdb-core/ainode/pom.xml | 94 +-
iotdb-core/ainode/pyproject.toml | 107 +-
.../ainode/resources/syncPythonVersion.groovy | 33 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 20 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 -
.../async/AsyncAINodeHeartbeatClientPool.java | 7 +-
.../request/read/model/ShowModelPlan.java | 4 +-
.../consensus/response/model/GetModelInfoResp.java | 8 +
.../exception/NoAvailableAINodeException.java | 27 -
.../iotdb/confignode/manager/ConfigManager.java | 49 +-
.../apache/iotdb/confignode/manager/IManager.java | 23 +-
.../iotdb/confignode/manager/ModelManager.java | 149 +-
.../iotdb/confignode/persistence/ModelInfo.java | 2 +
.../procedure/impl/model/CreateModelProcedure.java | 4 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 44 +-
.../db/protocol/client/AINodeClientFactory.java | 133 -
.../iotdb/db/protocol/client/ConfigNodeClient.java | 23 +-
.../client/ainode/AINodeClientManager.java | 75 -
.../table/v1/handler/ExecuteStatementHandler.java | 4 -
.../rest/v1/handler/ExecuteStatementHandler.java | 4 -
.../rest/v1/handler/QueryDataSetHandler.java | 4 -
.../rest/v2/handler/ExecuteStatementHandler.java | 4 -
.../rest/v2/handler/QueryDataSetHandler.java | 4 -
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 1 +
.../common/header/DatasetHeaderFactory.java | 8 -
.../operator/process/ai/InferenceOperator.java | 4 +-
.../InformationSchemaContentSupplierFactory.java | 17 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 -
.../queryengine/plan/analyze/AnalyzeVisitor.java | 10 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 23 +-
.../execution/config/TableConfigTaskVisitor.java | 32 -
.../execution/config/TreeConfigTaskVisitor.java | 33 -
.../config/executor/ClusterConfigTaskExecutor.java | 140 +-
.../config/executor/IConfigTaskExecutor.java | 8 -
.../config/metadata/ai/LoadModelTask.java | 45 -
.../config/metadata/ai/ShowAIDevicesTask.java | 64 -
.../config/metadata/ai/ShowLoadedModelsTask.java | 78 -
.../config/metadata/ai/ShowModelsTask.java | 4 +-
.../config/metadata/ai/UnloadModelTask.java | 45 -
.../db/queryengine/plan/parser/ASTVisitor.java | 55 -
.../parameter/model/ModelInferenceDescriptor.java | 5 +-
.../function/tvf/ForecastTableFunction.java | 22 +-
.../plan/relational/sql/ast/AstVisitor.java | 16 -
.../plan/relational/sql/ast/LoadModel.java | 73 -
.../plan/relational/sql/ast/ShowAIDevices.java | 59 -
.../plan/relational/sql/ast/ShowLoadedModels.java | 66 -
.../plan/relational/sql/ast/UnloadModel.java | 72 -
.../plan/relational/sql/parser/AstBuilder.java | 53 -
.../plan/statement/StatementVisitor.java | 20 -
.../metadata/model/LoadModelStatement.java | 89 -
.../metadata/model/ShowAIDevicesStatement.java | 51 -
.../metadata/model/ShowLoadedModelsStatement.java | 77 -
.../metadata/model/UnloadModelStatement.java | 89 -
.../db/queryengine/plan/udf/UDTFForecast.java | 270 ---
.../relational/analyzer/TableFunctionTest.java | 4 +-
iotdb-core/node-commons/pom.xml | 6 +
.../iotdb/commons/client/ClientPoolFactory.java | 52 +
.../iotdb/commons}/client/ainode/AINodeClient.java | 153 +-
.../commons/client/ainode/AINodeClientManager.java | 27 +-
.../client/ainode/AsyncAINodeServiceClient.java | 2 +-
.../schema/column/ColumnHeaderConstant.java | 11 -
.../db/relational/grammar/sql/RelationalSql.g4 | 24 -
.../thrift-ainode/src/main/thrift/ainode.thrift | 32 -
.../src/main/thrift/confignode.thrift | 35 +-
scripts/conf/ainode-env.sh | 138 ++
scripts/conf/windows/ainode-env.bat | 129 +
scripts/sbin/start-ainode.sh | 56 +-
scripts/sbin/windows/start-ainode.bat | 62 +-
194 files changed, 8291 insertions(+), 7715 deletions(-)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeConcurrentInferenceIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeInstanceManagementIT.java
delete mode 100644 iotdb-core/ainode/.flake8
delete mode 100644 iotdb-core/ainode/ainode.spec
copy iotdb-core/ainode/{iotdb/thrift => ainode}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/ai_node.py (87%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/config.py (81%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/constant.py (88%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/exception.py (96%)
rename iotdb-core/ainode/{iotdb/ainode/core =>
ainode/core/inference}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/inference/inference_request.py (84%)
create mode 100644
iotdb-core/ainode/ainode/core/inference/inference_request_pool.py
rename iotdb-core/ainode/{iotdb/ainode/core/inference =>
ainode/core/inference/scheduler}/__init__.py (100%)
rename
iotdb-core/ainode/{iotdb/ainode/core/inference/request_scheduler/abstract_request_scheduler.py
=> ainode/core/inference/scheduler/abstract_scheduler.py} (98%)
rename
iotdb-core/ainode/{iotdb/ainode/core/inference/request_scheduler/basic_request_scheduler.py
=> ainode/core/inference/scheduler/basic_scheduler.py} (89%)
rename iotdb-core/ainode/{iotdb/ainode/core/inference/batcher =>
ainode/core/inference/strategy}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/inference/strategy/abstract_inference_pipeline.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/inference/strategy/timer_sundial_inference_pipeline.py (88%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/inference/strategy/timerxl_inference_pipeline.py (71%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/inference/utils.py (100%)
rename iotdb-core/ainode/{iotdb/ainode/core/inference/dispatcher =>
ainode/core/ingress}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/ingress/dataset.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/ingress/iotdb.py (95%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/log.py (96%)
rename iotdb-core/ainode/{iotdb/ainode/core/inference/pool_scheduler =>
ainode/core/manager}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/manager/cluster_manager.py
(88%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/manager/inference_manager.py
(60%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/manager/model_manager.py (82%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/manager/utils.py (77%)
rename iotdb-core/ainode/{iotdb/ainode/core/inference/request_scheduler =>
ainode/core/model}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/built_in_model_factory.py (96%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/model/model_enums.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/model/model_factory.py (96%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/model/model_info.py (98%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/model/model_storage.py (93%)
rename iotdb-core/ainode/{iotdb/ainode/core/inference/strategy =>
ainode/core/model/sundial}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/sundial/configuration_sundial.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/model/sundial/flow_loss.py
(100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/sundial/modeling_sundial.py (97%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/sundial/ts_generation_mixin.py (100%)
rename iotdb-core/ainode/{iotdb/ainode/core/ingress =>
ainode/core/model/timerxl}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/timerxl/configuration_timer.py (100%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/timerxl/modeling_timer.py (98%)
rename iotdb-core/ainode/{iotdb =>
}/ainode/core/model/timerxl/ts_generation_mixin.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/model/uri_utils.py (94%)
rename iotdb-core/ainode/{iotdb/ainode/core/manager =>
ainode/core/rpc}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/rpc/client.py (80%)
create mode 100644 iotdb-core/ainode/ainode/core/rpc/handler.py
rename iotdb-core/ainode/{iotdb => }/ainode/core/rpc/service.py (69%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/rpc/status.py (89%)
create mode 100644 iotdb-core/ainode/ainode/core/script.py
rename iotdb-core/ainode/{iotdb/ainode/core/model =>
ainode/core/util}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/activation.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/cache.py (96%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/decorator.py (79%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/huggingface_cache.py
(100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/lock.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/masking.py (100%)
rename iotdb-core/ainode/{iotdb => }/ainode/core/util/serde.py (98%)
delete mode 100644 iotdb-core/ainode/build_binary.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/conf/git.properties
copy iotdb-core/ainode/{resources => iotdb/ainode/conf}/pom.properties (96%)
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/batcher/abstract_batcher.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/batcher/basic_batcher.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/dispatcher/abstract_dispatcher.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/dispatcher/basic_dispatcher.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/inference_request_pool.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_controller.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/inference/pool_group.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_scheduler/abstract_pool_scheduler.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/inference/pool_scheduler/basic_pool_scheduler.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/sundial/__init__.py
delete mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/timerxl/__init__.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/rpc/__init__.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/script.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/__init__.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/atmoic_int.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/batch_executor.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/gpu_mapping.py
delete mode 100644 iotdb-core/ainode/iotdb/ainode/core/util/thread_name.py
create mode 100644 iotdb-core/ainode/poetry.lock
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/exception/NoAvailableAINodeException.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/AINodeClientFactory.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ainode/AINodeClientManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/LoadModelTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/ShowAIDevicesTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/ShowLoadedModelsTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/UnloadModelTask.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/LoadModel.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowAIDevices.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/ShowLoadedModels.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/UnloadModel.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/LoadModelStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowAIDevicesStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowLoadedModelsStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/UnloadModelStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/udf/UDTFForecast.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol =>
node-commons/src/main/java/org/apache/iotdb/commons}/client/ainode/AINodeClient.java
(67%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/RoundRobinPolicy.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClientManager.java
(56%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol =>
node-commons/src/main/java/org/apache/iotdb/commons}/client/ainode/AsyncAINodeServiceClient.java
(98%)
create mode 100644 scripts/conf/ainode-env.sh
create mode 100644 scripts/conf/windows/ainode-env.bat
